现象
服务器启动后出现SkyWalking内的kafka异常
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)
原因分析
SkyWalking对kafka_0.11以下的header不支持。
github上作者回复：
处理方案
- 升级kafka server到0.11.x及以上版本
- 或者不用skywalking...
| 
转播
