模擬配置kafka服務器后用簡單的java客戶端發(fā)送消息但是不見消息儲存一直只能看到這個報錯日志(消息確實沒有儲存)
kafka.common.KafkaException: Wrong request type 18
at kafka.api.RequestKeys$.deserializerForKey(RequestKeys.scala:64)
at kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:50)
at kafka.network.Processor.read(SocketServer.scala:450)
at kafka.network.Processor.run(SocketServer.scala:340)
at java.lang.Thread.run(Thread.java:745)
[2018-03-24 11:12:14,032] ERROR Closing socket for /192.168.23.1 because of error (kafka.network.Processor)
kafka.common.KafkaException: Wrong request type 18
at kafka.api.RequestKeys$.deserializerForKey(RequestKeys.scala:64)
at kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:50)
at kafka.network.Processor.read(SocketServer.scala:450)
at kafka.network.Processor.run(SocketServer.scala:340)
at java.lang.Thread.run(Thread.java:745)
[2018-03-24 11:12:14,087] ERROR Closing socket for /192.168.23.1 because of error (kafka.network.Processor)
kafka.common.KafkaException: Wrong request type 18
at kafka.api.RequestKeys$.deserializerForKey(RequestKeys.scala:64)
at kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:50)
at kafka.network.Processor.read(SocketServer.scala:450)
at kafka.network.Processor.run(SocketServer.scala:340)
at java.lang.Thread.run(Thread.java:745)
[2018-03-24 11:12:14,140] ERROR Closing socket for /192.168.23.1 because of error (kafka.network.Processor)
kafka.common.KafkaException: Wrong request type 18
at kafka.api.RequestKeys$.deserializerForKey(RequestKeys.scala:64)
at kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:50)
at kafka.network.Processor.read(SocketServer.scala:450)
at kafka.network.Processor.run(SocketServer.scala:340)
at java.lang.Thread.run(Thread.java:745)
[2018-03-24 11:12:14,244] ERROR Closing socket for /192.168.23.1 because of error (kafka.network.Processor)
kafka.common.KafkaException: Wrong request type 18
at kafka.api.RequestKeys$.deserializerForKey(RequestKeys.scala:64)
at kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:50)
at kafka.network.Processor.read(SocketServer.scala:450)
at kafka.network.Processor.run(SocketServer.scala:340)
at java.lang.Thread.run(Thread.java:745)
畢竟是java客戶端寫了死循環(huán)輸出消息所以多余重復的日志就不多寫了小弟個人覺得是zookeeper這里或是kafka這里設置的消息大小有問題,但是確實不知道改哪里,求大神指導
下面是簡易java客戶端的代碼···javaimport org.apache.kafka.clients.producer.KafkaProducer;import org.apache.kafka.clients.producer.ProducerRecord;import java.util.Properties;public class ProducerTest {
public static void main(String[] args) {
//todo:1、配置文件
Properties props = new Properties();
props.put("bootstrap.servers","node1:9092");
props.put("acks","all");
props.put("retries",0);
props.put("batch.size",16384);
props.put("linger.ms",1);
props.put("buffer.memory",33554432);
props.put("key.serializer","org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer","org.apache.kafka.common.serialization.StringSerializer");
//todo:2、創(chuàng)建kafkaProducer
KafkaProducer<String,String> kafkaProducer = new KafkaProducer<String,String>(props);
for (int i = 0; i <100; i++){
//todo:3、發(fā)送數(shù)據(jù)給kafka
kafkaProducer.send(new ProducerRecord<String, String>
("test","sdfafasdgfak",
"Consumer Group(dfsadfa fasfasfasefawe4fawefawe fawef awfa)"));
}
}
}···
1 回答

GCT1015
TA貢獻1827條經(jīng)驗 獲得超4個贊
這個問題是由于你服務器上的kafka版本和你代碼中配置的kafka版本不一致導致的,比如你服務器上部署的是2.1.10 這個對應你本地開發(fā)環(huán)境中maven中kafka的版本號是0.8.10 但是你開發(fā)的時候用的卻是2.1.12 這樣就會出現(xiàn)這個問題
添加回答
舉報
0/150
提交
取消