我正试着用Kafka的控制台制作工具来制作消息。但最终会出现以下错误。
$ /usr/bin/kafka-console-producer --broker-list confluent-kafka-0-service.ms-kafka-internal.svc:9092 --topic testTopic --producer.config ~/etc/kafka/client_security.properties
[2020-08-09 06:37:52844]信息Kafka版本:5.4.2-ccs(org.apache.kafka.common.utils.appinfoparser)[2020-08-09 06:37:52845]信息Kafka委员会:2626d8cfb686c23e(org.apache.kafka.common.utils.appinfoparser)[2020-08-09 06:37:52845]信息Kafka启动:1596955072646(org.apache.kafka.common.utils.appinfoparser)
您好,欢迎使用confluent kafka[2020-08-09 06:38:55451]向主题testtopic发送消息时出错键为null,值为2字节,错误为:(org.apache.kafka.clients.producer.internals.errorloggingcallback)org.apache.kafka.common.errors.timeoutexception:主题testtopic在60000毫秒后元数据中不存在。
我已经运行了下面的consumer命令来查看消息。但也没有看到任何消息。
/usr/bin/kafka-console-consumer --bootstrap-server confluent-kafka-0-service.ms-kafka-internal.svc:9092 --topic testTopic --from-beginning --consumer.config ~/etc/bmw/kafka/client_security.properties
如能立即提供帮助,我们将不胜感激。
谢谢,米娜
2条答案
按热度按时间hmtdttj41#
mutmk8jj2#
请注意,生产者和消费者指向不同的路径:
--consumer.config~/etc/bmw/kafka/client\u security.properties
与
--producer.config~/etc/kafka/client\ u security.propertie
也许你只是得到了错误的配置文件路径?