在kafka的config文件夾中的server.config：
在#listeners=PLAINTEXT://:9092下加一行
listeners=PLAINTEXT://localhost:9092
參考：https://www.jianshu.com/p/b6a5045434c4
【轉】Kafka 寫消息失敗--org.apache.kafka.common.errors.TimeoutException
免責聲明！
本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。
猜您在找
java代碼向kafka集群發送消息報org.apache.kafka.common.errors.TimeoutException: Batch Expired
kafka基礎：解決org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for xxx topic
kafka2.11-0.9.0.0實現Producer發送消息時，無法發送，報錯信息：org.apache.kafka.common.errors.TimeoutException: Batch Expired
kafka創建topic報錯ERROR org.apache.kafka.common.errors.InvalidReplicationFactorException
kafka 異常：org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host
org.apache.kafka.common.errors.SerializationException: Error deserializing... Caused by: org.apache.kafka.common.errors.SerializationException: Size of data received by IntegerDeserializer is not 4
kafka刪除topic后再創建同名的topic報錯（ERROR org.apache.kafka.common.errors.TopicExistsException）
org.apache.kafka.common.network.Selector
Kafka 啟動失敗，報錯Corrupt index found以及org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'version': java.nio.BufferUnderflowException
Error starting the context, marking it as stopped org.apache.kafka.common.KafkaException: Failed to construct kafka consumer