Kafka-console-producer返回主题超时错误
$ /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
/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
任何立即的帮助都将不胜感激。
谢谢，米娜
共有1个答案
请注意，您的生产者和消费者指向不同的路径：
--consumer.config~/etc/bmw/kafka/client_security.properties
VS
-
我正在尝试使用kafka-avro-convore-生产者发布一条具有键（带有模式）和值（带有模式）的消息。kafka环境（kafka的conFluent 6.2.0版本、连接、zoomaster、模式注册表）都正确启动，我可以确认我的连接器已安装。问题是当我发送消息时，我的Sink连接器失败并出现我无法诊断的错误。 感谢您的帮助： 我生成一条AVRO消息，如下所示： 并在连接日志中接收以下错误：
-
我如何通过可能从application.yml中插入“+死信”来设置相同的Kafka主题？我试过这样一件事： 但它给我创造了两个同名的不同主题。我正在等待一些建议，谢谢你的帮助！
-
我们正在尝试使用托管在Windows独立环境中的Kafka中的代理消息。消费者正在Kubernetes中运行。 Server.Properties： 请帮助我解决这个问题。
-
我是Kafka的新用户，我们在应用程序中使用了Spring Web Flux。我们需要向两个不同的主题推送两个不同的消息，比如T1和T2。Kafka经纪人也是一样。我们正在使用ReactiveKafkaProducerTemplate，效果很好。 现在我们只需要单独压缩一个主题[T1]内容，因为消息大小在主题T1上更大。我们是否在响应式Kafka或Project Actor中支持路由KafkaTe
-
我已经编写了简单的aws lambda代码，以便在alexa skills kit控制台上输出，但我经常得到null的输出。我已确保将aws lambda中的arn粘贴到技能的endpoint。不知道为什么会这样。 aws lambda代码 alexa skills json输出
-
我试图使用kafka-avro-console-producer 5.4.0-ccs不自动注册模式。我试着用： 但它仍然在注册模式。属性似乎正确:https://github.com/confluentinc/schema-registry/blob/a0a04628687a72ac6d01869d881a60fbde4177e7/avro-serializer/src/main/java/io/