You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Micah Ramos (Jira)" <ji...@apache.org> on 2020/02/21 01:25:00 UTC

[jira] [Created] (KAFKA-9584) Removing headers causes ConcurrentModificationException

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)