百谷博客

键盘平天下 

2019-07-15 16:20 来自 百谷博客

kafka报错：java.lang.IllegalArgumentException: Magic v1 does not support record headers

这个报错是因为kafka server的版本过低，建议更换kafka server完整报错java.lang.IllegalArgumentException: Magic v1 does not support record headers at org.apac...

键盘平天下 

2018-11-19 20:43 来自 百谷博客

kafka 报错解决kafka.common.TopicExistsException: Topic "XXX" already exists.

kafka 报错：kafka.common.TopicExistsException: Topic "XXX" already exists.怀疑是kafka和zookeeper不一致导致，在${kafka_home}/config/server.properties 中加...

键盘平天下 

2018-10-16 18:38 来自 百谷博客

kafka报错Can't convert value of class java.lang.String to class org.apache.kafka.common.serialization.ByteArraySerializer specified in value.serializer

kafka 发消息报错org.apache.kafka.common.errors.SerializationException: Can't convert value of class java.lang.String to class org.apache.kafka...

键盘平天下 

2018-09-30 13:15 来自 百谷博客

kafka报错could not be established. Broker may not be available.

原因查出来是kafka gg了，进程不在了,注意这条命令也会生成一个进程执行，所以搜索出来的结果如果只有一条，表示kafka进程不在了哦。 ps -ef | grep kafka 重启kafka，问题解决bin/kafka-server-start.sh config/se...