Micah Ramos created KAFKA-9584:
----------------------------------
Summary: Removing headers causes ConcurrentModificationException
Key: KAFKA-9584
URL: https://issues.apache.org/jira/browse/KAFKA-9584
Project: Kafka
Issue Type: Bug
Components: streams
Affects Versions: 2.0.0
Reporter: Micah Ramos
The consumer record that is used during punctuate is static, this can cause
java.util.ConcurrentModificationException when modifying the headers.
Using a single instance of ConsumerRecord for all punctuates causes other
strange behavior:
# Headers are shared across partitions.
# A topology that adds headers could append an infinite number of headers,
causing memory problems in the current topology as well as down stream
consumers since the headers are produced when the records is produced to a
topic.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
