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: [email protected] With regards, Apache Git Services
