我在Windows子系统Linux上安装了kafka,并开始使用命令confluent本地
服务启动,所有服务都已启动。现在,当我尝试从Windows运行我的kafka-spring应用程序时,它显示以下错误:- 无法建立与节点-1(localhost/127.0.0.1:9092)的连接。经纪人可能不可用。
我的服务器属性是:-
listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://localhost:9092
我哪里出错了???
您需要在WSL2会话中运行Spring应用程序,这样它就和hypervisor在同一个网桥上
问题内容: 我有以下结构: 通过kafka-topics shell脚本创建了具有复制因子3和分区3的主题。 并使用组localConsumers。领导没事的时候工作正常。 消费者日志 但是,如果领导者倒下了-我在消费者中遇到了错误(systemctl stop kafka): 节点3不可用。好 消费者日志 使用者无法连接,直到领导者掉线或与另一个使用者组重新连接。 不明白为什么会这样?消费者应重
当spring-boot应用程序运行时,如果我完全关闭代理程序(包括kafka和zookeeper),我会在控制台中看到这个警告,持续很长时间。 [org.springframework.kafka.kafkalistenerendpointcontainer#0-0-c-1]警告o.apache.kafka.clients.networkclient-[Consumer clientid=con
我在Zookeeper和Kafka(各1个实例)中运行我的locahost。 我成功地从Kafka创建了一个主题: Kafka日志显示: 但Zookeeper的日志显示: 如果我尝试生成消息: server.properties(在Kafka中)是: 看来动物园管理员没有注册任何经纪人。 有什么建议吗?
当尝试在 CentOS 上使用 Python 客户端本地连接到 Kafka 0.10.0.0 时,我有一个非常奇怪的问题。 我的连接选项非常简单且默认: 当我在Kafka的服务器中手动设置侦听器选项时。属性文件,如: 我得到了kafka.errors。NoBrokersAvailable,尽管我仍然可以使用curl或其他linux工具轻松连接到Kafka代理服务器。 无广告。侦听器或其他不推荐使用
我正在尝试仅为代理间kerberos配置Kafka代理。然而,由于它似乎也想通过Kerberos连接到Zookeeper,所以我似乎总是遇到错误。我目前还没有设置任何Zookeeper键。 我的Kafka代理 JAAS 配置如下: 服务器属性 我用上述配置得到的错误如下: 换句话说,我只想要经纪人到经纪人的 kerberos 和经纪人 - 动物园管理员的普通SASL_SSL。这可能吗?
我正在开发一个POC,用于在我的项目中实现一个kafka集群。我已经在我的本地机器中设置了一个有3个经纪人的kafka集群。现在,我正在使用Spring MVC REST服务向Kafka服务器发送消息,该服务在内部使用Spring Kafka来生成和使用往返于Kafka集群的消息。现在我正在尝试在代理关闭时,当使用者无法接收来自主题的消息时发送警报。我关闭使用者连接到的唯一代理。我的日志中没有任何