nifi-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From GitBox <...@apache.org>
Subject [GitHub] [nifi] mattyb149 commented on issue #3854: NIFI-6819: Add KafkaRecordSink implementations for Kafka 1 and 2
Date Tue, 05 Nov 2019 15:54:39 GMT
mattyb149 commented on issue #3854: NIFI-6819: Add KafkaRecordSink implementations for Kafka
1 and 2
URL: https://github.com/apache/nifi/pull/3854#issuecomment-549884179
 
 
   I updated the versions to 1.11 and found a bug where I wasn't closing the producer when
the CS was disabled so I added some cleanup code. I also found some references to "Flow Files"
when I'd copied some properties from the PublishKafkaRecord processor(s) so I corrected those.
   
   I was able to verify that when the offsets replication factor is higher than the number
of brokers, the data doesn't get published but no error or information is returned to the
client. I agree with Yolanda that this is https://issues.apache.org/jira/browse/KAFKA-5666
and unfortunately there is no workaround at the client side.

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services

Mime
View raw message