# Error in transaction creation based on Kafka record

**URL:** <https://discuss.elastic.co/t/error-in-transaction-creation-based-on-kafka-record/274927>\
**Category:** APM\
**Tags:** java, server\
**Created:** [June 3, 2021, 10:15pm UTC](https://discuss.elastic.co/t/error-in-transaction-creation-based-on-kafka-record/274927 "2021-06-03T22:15:08Z")\
**Posts on this page:** 3\
**Page:** 1

<div class="post-metadata">

**Author:** ![saelastic](https://avatars.discourse-cdn.com/v4/letter/s/34f0e0/32.png) [@saelastic](https://discuss.elastic.co/u/saelastic)\
**Post date:** [June 3, 2021, 10:15pm UTC](https://discuss.elastic.co/t/error-in-transaction-creation-based-on-kafka-record/274927/1 "2021-06-03T22:15:08Z")

</div>

**Kibana version** :  
7.11.2  
**Elasticsearch version** :  
7.11.2  
**APM Server version** :  
7.11.2  
**APM Agent language and version** :  
java - 1.22.0

**Original install method (e.g. download page, yum, deb, from source, etc.) and version**:  
java client jar

**Description of the problem including expected versus actual behavior. Please include screenshots**

Our Application logs show

`ERROR co.elastic.apm.agent.kafka.helper.ConsumerRecordsIteratorWrapper - Error in transaction creation based on Kafka record`

Our insights are around a message headers key/value having a null value and apm failing to capture such messages .

**Provide logs and/or server output (if relevant)**:

```auto

    at java.lang.Thread.run(Thread.java:834) [?:?]
    2021-06-03 17:01:55	
    
    	at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
    2021-06-03 17:01:55	
    
    	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
    2021-06-03 17:01:55	
  
    	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1073) [spring-kafka-2.6.4.jar!/:2.6.4]
    2021-06-03 17:01:55	
    
    	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1176) [spring-kafka-2.6.4.jar!/:2.6.4]
    2021-06-03 17:01:55	
  
    	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1529) [spring-kafka-2.6.4.jar!/:2.6.4]
    2021-06-03 17:01:55	

    	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1810) [spring-kafka-2.6.4.jar!/:2.6.4]
    2021-06-03 17:01:55	
  
    	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1911) [spring-kafka-2.6.4.jar!/:2.6.4]
    2021-06-03 17:01:55	
   
    	at co.elastic.apm.agent.kafka.helper.ConsumerRecordsIteratorWrapper.next(ConsumerRecordsIteratorWrapper.java:42) [?:?]
    2021-06-03 17:01:55	
    
    	at co.elastic.apm.agent.kafka.helper.ConsumerRecordsIteratorWrapper.next(ConsumerRecordsIteratorWrapper.java:100) [?:?]
    2021-06-03 17:01:55	
   
    	at co.elastic.apm.agent.impl.context.Message.addHeader(Message.java:127) ~[?:?]
    2021-06-03 17:01:55	
   
    	at co.elastic.apm.agent.impl.context.Headers.add(Headers.java:47) ~[?:?]
    2021-06-03 17:01:55	
  
    	at co.elastic.apm.agent.util.BinaryHeaderMap.add(BinaryHeaderMap.java:76) ~[?:?]
    2021-06-03 17:01:55	
    
    	at co.elastic.apm.agent.util.IOUtils.decodeUtf8Bytes(IOUtils.java:130) ~[?:?]
    2021-06-03 17:01:55	
    
    java.lang.NullPointerException: null

```

---

<div class="post-metadata">

**Author:** ![Sylvain\_Juge](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/sylvain_juge/32/55521_2.png) [@Sylvain\_Juge](https://discuss.elastic.co/u/Sylvain_Juge)\
**Post date:** [June 4, 2021, 7:07am UTC](https://discuss.elastic.co/t/error-in-transaction-creation-based-on-kafka-record/274927/2 "2021-06-04T07:07:06Z")

</div>

For reference, here is the link to the related [issue in the java agent](https://github.com/elastic/apm-agent-java/issues/1840).

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [June 25, 2021, 3:07am UTC](https://discuss.elastic.co/t/error-in-transaction-creation-based-on-kafka-record/274927/3 "2021-06-25T03:07:31Z")

</div>

This topic was automatically closed 20 days after the last reply. New replies are no longer allowed.