szaboferee commented on issue #3439: NIFI-6218 Support setting transactional.id in PublishKafka/PublishKaf… URL: https://github.com/apache/nifi/pull/3439#issuecomment-496489231 Thank you @ijokarumawak for the review and the good suggestion. The goal is to let the user specify Kafka ACLs or Ranger policies based on transactional ids or at least on a pattern that matches the transaction ids. The new solution is a transactional id prefix property. This way a processor can be configured to have a unique but matching transactional id. As the FlowFiles are processed in transactions, fortunately, we do not have to keep the previous KafkaProducer with the same transactional id when an error occurs. If everything is working without error, the KafkaProducer will be reused.
---------------------------------------------------------------- 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
