在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