Alaksiej Ščarbaty created NIFI-14584:
----------------------------------------
Summary: Add synchronization on consumers in ConsumeKafka
Key: NIFI-14584
URL: https://issues.apache.org/jira/browse/NIFI-14584
Project: Apache NiFi
Issue Type: Improvement
Components: Extensions
Reporter: Alaksiej Ščarbaty
Assignee: Alaksiej Ščarbaty
When Kafka flow in stateless mode times out (due to any reason), the
_ConsumeKafka_ rollback ({_}commitAsync{_} callback) is called from another
thread than the main thread of the flow.
Due to the built in mechanism in _ClassicKafkaConsumer_ a
_ConcurrentModificationException_ is thrown.
Any interaction with a Kafka consumer should be synchronized.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
