【发布时间】:2017-04-26 16:07:14
【问题描述】:
使用java我正在向kafka发送json object,最初它为我工作了2天,现在我收到了以下exception
Exception in thread "main" java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.valueOrError(FutureRecordMetadata.java:65)
at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:52)
at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:25)
at dummy.DummySyntheticManifestProducer.main(DummySyntheticManifestProducer.java:164)
Caused by: org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
【问题讨论】:
-
感谢您发布此信息。还可以提供一些信息,说明您看到此问题的 Kafka 设置如何?您使用的是集群还是独立服务器?你用的是什么版本的 Kafka?
标签: java apache-kafka kafka-producer-api