在minikube上的Kafka控制台生产者/消费者ERROR将消息发送到主题时出错

如何解决在minikube上的Kafka控制台生产者/消费者ERROR将消息发送到主题时出错

我试图在我的minikube集群中使用kafka控制台的生产者和使用者。

这些是我的服务

NAME            TYPE        CLUSTER-IP       EXTERNAL-IP   PORT(S)           AGE
java-api        NodePort    10.108.162.108   <none>        8080:30141/TCP    8d
kafka-service   NodePort    10.104.71.239    <none>        29092:32676/TCP   66m
kubernetes      ClusterIP   10.96.0.1        <none>        443/TCP           12d
zookeeper       ClusterIP   10.106.78.82     <none>        2181/TCP          66m

我的部署

NAME        READY   UP-TO-DATE   AVAILABLE   AGE
java-api    1/1     1            1           8d
kafka       1/1     1            1           141m
zookeeper   1/1     1            1           141m

我的豆荚

NAME                         READY   STATUS    RESTARTS   AGE
java-api-55ff8cbf8b-xkrcj    1/1     Running   0          8d
kafka-77486f8d89-jhgtk       1/1     Running   0          143m
zookeeper-64b8b5cf6b-bt67h   1/1     Running   0          143m

我运行kubectl exec -it kafka-77486f8d89-jhgtk /bin/bash

当我跑步时:

kafka-console-consumer.sh --bootstrap-server 10.104.71.239:29092 --topic Kafka_Example --from-beginning

我明白了:

WARN [Consumer clientId=consumer-console-consumer-60284-1,groupId=console-consumer-60284] Connection to node -1 (/10.104.71.239:29092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

当我跑步时: kafka-console-producer.sh --broker-list 10.104.71.239:29092 --topic Kafka_Example

一段时间后我得到了:

[2020-09-29 11:46:23,697] ERROR Error when sending message to topic Kafka_Example with key: null,value: 3 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
org.apache.kafka.common.errors.TimeoutException: Topic Kafka_Example not present in metadata after 60000 ms.

主题存在:

I have no name!@kafka-77486f8d89-jhgtk:/bin$ kafka-topics.sh --list --zookeeper zookeeper:2181
Example_Topic
Kafka_Example

解决方法

我删除了

类型:节点端口

kafka服务,现在消费者和生产者都在容器中工作。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


Selenium Web驱动程序和Java。元素在(x,y)点处不可单击。其他元素将获得点击?
Python-如何使用点“。” 访问字典成员?
Java 字符串是不可变的。到底是什么意思?
Java中的“ final”关键字如何工作?(我仍然可以修改对象。)
“loop:”在Java代码中。这是什么,为什么要编译?
java.lang.ClassNotFoundException:sun.jdbc.odbc.JdbcOdbcDriver发生异常。为什么?
这是用Java进行XML解析的最佳库。
Java的PriorityQueue的内置迭代器不会以任何特定顺序遍历数据结构。为什么?
如何在Java中聆听按键时移动图像。
Java“Program to an interface”。这是什么意思?
Java在半透明框架/面板/组件上重新绘画。
Java“ Class.forName()”和“ Class.forName()。newInstance()”之间有什么区别?
在此环境中不提供编译器。也许是在JRE而不是JDK上运行?
Java用相同的方法在一个类中实现两个接口。哪种接口方法被覆盖?
Java 什么是Runtime.getRuntime()。totalMemory()和freeMemory()?
java.library.path中的java.lang.UnsatisfiedLinkError否*****。dll
JavaFX“位置是必需的。” 即使在同一包装中
Java 导入两个具有相同名称的类。怎么处理?
Java 是否应该在HttpServletResponse.getOutputStream()/。getWriter()上调用.close()?
Java RegEx元字符(。)和普通点?