获取错误:“org.apache.kafka.clients.NetworkClient:[Consumer ClientID=Consumer-1,GroupID=Inter]无法建立到节点-1的连接。代理可能不可用。”
我尝试将Java版本切换到11和8以及各种属性
spring:
kafka:
consumer:
#bootstrap-servers: localhost:9092
group-id: inter
auto-offset-reset: earliest
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
producer:
bootstrap-servers: localhost:9092
@Service
public class KafkaHalloWorldMessagingService {
private KafkaTemplate<String, String> kafkaTemplate;
@Autowired
public KafkaHalloWorldMessagingService(KafkaTemplate<String, String> kafkaTemplate) {
this.kafkaTemplate = kafkaTemplate;
}
public void sendHalloToTheSystem(String messageToSend) {
kafkaTemplate.send("interlinked.hallo.topic", messageToSend);
}
}
@Component
public class KafkaHalloWorldListener {
@KafkaListener(topics = "interlinked.hallo.topics", groupId = "inter")
public void handle(String messageToListenTo) {
System.out.println(messageToListenTo.toUpperCase());
}
}
2019-08-22 16:25:20.580警告5865---[restartedMain]org.apache.kafka.clients.NetworkClient:[Consumer ClientID=Consumer-1,GroupID=Inter]无法建立到节点-1连接。代理可能不可用。
确保yml文件中的引导服务器值和Kafka server.properties文件中的侦听器相同。
更新server.properties文件中的这两个值。可以在Kafka下载目录的config文件夹中看到。
zookeeper.connect=您的IpV4 Addrees:2181
为什么使用者的引导带服务器属性会被注释掉呢?
请也为消费者使用生产者的引导带服务器值。生产者:bootstrap-servers:=您的IpV4 Addrees:9092消费者:bootstrap-servers:=您的IpV4 Addrees:9092:
希望你的饲养员和Kafaka起来了。
我试图用Spring Boot 2.1.7启动Spring-Kafka。用Java12在localhost上发布。
我在Zookeeper和Kafka(各1个实例)中运行我的locahost。 我成功地从Kafka创建了一个主题: Kafka日志显示: 但Zookeeper的日志显示: 如果我尝试生成消息: server.properties(在Kafka中)是: 看来动物园管理员没有注册任何经纪人。 有什么建议吗?
我正试图在我的本地(windows 7虚拟桌面)中使用来自Kafka的消息 Zookeeper和kafka在同一台本地计算机上运行 创建主题 produce message kafka-console-producer--broker-list 127.0.0.1:9092--topic first_topic没有错误,我只是做Ctrl+C do end producing 使用邮件
问题内容: 我只是不明白发生了什么。我的go应用程序无法连接到elasticsearch。该节点可用,已启动并正在运行。我在这里做错了什么? 这里有什么不对的地方?错误说 这是我在浏览器中命中GET请求时从elasticsearch返回的数据 } 问题答案: 当您继续在客户端中进行嗅探但群集没有可用节点时,通常会发生错误。您可以通过点击来检查集群的状态。 如果您不禁用嗅探功能,则Golang客户端
问题内容: 我只是不明白发生了什么。我的go应用程序无法连接到弹性搜索。该节点可用,已启动并正在运行。我在这里做错了什么? 这里有什么不对的地方?错误说 这是我在浏览器中命中GET请求时从弹性搜索返回的数据 } 问题答案: 当您继续在客户端中进行嗅探但群集没有可用节点时,通常会发生错误。您可以通过点击来检查集群的状态。 如果您不禁用嗅探功能,则Golang客户端将在后台运行进程,该进程每15分钟轮
下面是Qpid客户端的配置,使用Camel上下文连接Artemis Broker。 上下文文件正像预期的那样开始,但是在本例中,qpid客户机无法连接到Apache Artemis 2.14.0代理。 我所看到的只是消费者端的一些线程块。 common-context.xml 注意:在使用CAMEL2.20.0版本时,即使在所有上下文都得到的情况下,这个单个xml文件中也有两个camel上下文