kafka timeoutexception：60000 ms之后的元数据中不存在主题

发布于 2025-02-13 10:20:40 字数 925 浏览 0 评论 0原文

我正在尝试一些kafka基础知识，并在。启动Zookeepier和Kafka之后，我尝试使用包含的Kafka Shell脚本生产和消费，这一切都无问题。当我尝试从简单的Scala应用程序中产生消息时，我会得到以下错误org.apache.kafka.kafka.common.errors.timeoutexception：topic quick QuickStart-Evesent在60000 ms之后不存在于元数据中。> 我确保了该主题已被创建，并且可以远程传播到Localhost：9092。

这是我用于生产者的代码：

val props = new Properties()
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092")
props.put(ProducerConfig.CLIENT_ID_CONFIG, "test")
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, classOf[StringSerializer].getName)
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, classOf[StringSerializer].getName)

val producer = new KafkaProducer[String, String](props)
producer.send(new ProducerRecord[String, String]("quickstart-events", "1", "some event")).get()

在Mac上运行此信息，上面的代码是Intellij中执行的测试用例的一部分。

原文

I'm trying out with some Kafka basics and following examples at https://kafka.apache.org/quickstart. After starting zookeepier and kafka, I tried producing and consuming with included kafka shell scripts and it all worked without issue.
When I try to produce message from simple scala application then I get following error org.apache.kafka.common.errors.TimeoutException: Topic quickstart-events not present in metadata after 60000 ms.
I ensured the topic has been created and can telnet to localhost:9092 as well.

Here's the code I'm using for producer:

val props = new Properties()
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092")
props.put(ProducerConfig.CLIENT_ID_CONFIG, "test")
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, classOf[StringSerializer].getName)
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, classOf[StringSerializer].getName)

val producer = new KafkaProducer[String, String](props)
producer.send(new ProducerRecord[String, String]("quickstart-events", "1", "some event")).get()

Running this on mac, above code is part of a test case executed in IntelliJ.

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

心作怪 2025-02-20 10:20:40

已解决。我使用kafka-clients库版本2.6.0并运行kafka服务器版本3.2.0。库的匹配版本解决了问题。

回复收藏 0 原文

物价感观 2025-02-20 10:20:40

我也遇到了这个问题，版本对我来说是正确的。
我发现这是缺乏SASL认证。
尝试：


// set SASL configuration here
props.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, “SASL_PLAINTEXT”);
props.put(SaslConfigs.SASL_MECHANISM, “PLAIN”);
props.put(“sasl.jaas.config”,
“org.apache.kafka.common.security.plain.PlainLoginModule required username=\”alice\” password=\”123456\”;”);

I got this problem as well, the version is correct for me.
I figure out it's the lack of sasl certification.
try:


// set SASL configuration here
props.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, “SASL_PLAINTEXT”);
props.put(SaslConfigs.SASL_MECHANISM, “PLAIN”);
props.put(“sasl.jaas.config”,
“org.apache.kafka.common.security.plain.PlainLoginModule required username=\”alice\” password=\”123456\”;”);

回复收藏 0 原文

~没有更多了~