【问题标题】:org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partitionorg.apache.kafka.common.errors.UnknownTopicOrPartitionException:此服务器不托管此主题分区
【发布时间】: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


【解决方案1】:

在生产者设置中设置retries 属性。 还需要将属性max.in.flight.requests.per.connection设置为1

【讨论】:

  • 为什么这能解决您的问题?
猜你喜欢
  • 2018-05-25
  • 2023-04-05
  • 2020-03-30
  • 1970-01-01
  • 1970-01-01
  • 2014-04-02
  • 2013-03-31
  • 1970-01-01
  • 2019-01-13
相关资源
最近更新 更多