日誌現象

java.lang.IllegalArgumentException: Magic v1 does not support record headers
	at org.apache.kafka.common.record.MemoryRecordsBuilder.appendWithOffset(MemoryRecordsBuilder.java:410)
	at org.apache.kafka.common.record.MemoryRecordsBuilder.appendWithOffset(MemoryRecordsBuilder.java:449)
	at org.apache.kafka.common.record.MemoryRecordsBuilder.append(MemoryRecordsBuilder.java:506)
	at org.apache.kafka.common.record.MemoryRecordsBuilder.append(MemoryRecordsBuilder.java:529)
	at org.apache.kafka.clients.producer.internals.ProducerBatch.tryAppend(ProducerBatch.java:107)
	at org.apache.kafka.clients.producer.internals.RecordAccumulator.append(RecordAccumulator.java:223)
	at org.apache.kafka.clients.producer.KafkaProducer.doSend$original$49W0MjDt(KafkaProducer.java:864)
	at org.apache.kafka.clients.producer.KafkaProducer.doSend$original$49W0MjDt$accessor$sAU9JM4M(KafkaProducer.java)
	at org.apache.kafka.clients.producer.KafkaProducer$auxiliary$4dlIPi13.call(Unknown Source)
	at org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.InstMethodsInterWithOverrideArgs.intercept(InstMethodsInterWithOverrideArgs.java:85)
 

根因分析

kafka_0.11版本以下對header的不支援。

gitbug上作者回復

解決方案

1、升級kafka server到0.11.x及以上版本；

2、將Skywalking的Agent中關於Kafka的外掛移除，但是這樣就會帶來一個問題，那就是kafka上下游的服務兩路不能夠串起來了；

3、移除Skywalking。