Spring Kafka中断开broker检测

文章/答案/技术大牛

发布

1回答

spring-kafka

我正在尝试为我的Kafka消费者写一份健康检查。当应用程序启动并运行时，我关闭了Kafka，我看到了很多在日志中，但没有ApplicationEvents，调用了错误处理程序，什么都没有。我的理解是，当代理断开连接时，会生成一个ApplicationEvent。我是不是遗漏了什么？

浏览 8提问于2021-05-14得票数 1

回答已采纳

1回答

引导代理断开连接的=> KeeperErrorCode = NoNode for / broker /topcis/xxxx/分区/2/state+ Key no

apache-kafka、kafka-consumer-api

我正在尝试运行kafka-控制台-consume.sh的主题XXX。断开 sh kafka-console-producer.sh --broker-list abcd:9092, bcde:9092, cdef:9092 警

浏览 0提问于2019-06-03得票数 0

2回答

我有一个Spring引导项目，它具有使用kafka进行日志记录的依赖项。我无法摆脱这种依赖关系，因为我的逻辑需要依赖关系中的代码我想在不运行kafka的情况下在本地启动该应用程序，这样我就可以测试我的简单数据库查找代码。我已尝试禁用自动配置 spring.autoconfigure.exclude=org.springframework.boot.autoconfigure.kafka.KafkaAutoConfigurationreturn factory; } 但是很明显，这个设置

浏览 37提问于2020-04-15得票数 2

1回答

Zipkin Docker不消费kafka "zipkin“主题

apache-kafka、docker-compose、zipkin

://${DOCKER_HOST_IP:-127.0.0.1}:9092 KAFKA_BROKER_ID“被推送到kafka，因为我可以在我的spring应用程序中使用它。Spring实现的application.properties中的zipkin设置如下所示。spring.zipkin.

浏览 70提问于2021-07-19得票数 0

2回答

EmbeddedKafkaRule没有brokerListProperty方法

java、spring-boot、spring-kafka

在参考的过程中，我发现了中的错误。EmbeddedKafkaRule类中没有brokerListProperty()方法。我应该如何重构代码以使其正常工作？以上链接中的代码：@SpringBootTest

浏览 6提问于2020-02-17得票数 2

回答已采纳

1回答

Spring-Kafka没有选择SSL配置。

java、spring-boot、ssl、apache-kafka、spring-kafka

我正试图连接到Kafka broker，后者执行双向SSL/TLS来验证和授权客户端。我已经通过正确的权限创建了证书签名，并存储在我的本地用户目录中。我在用我的application.propertiesspring.kafka</

浏览 5提问于2022-08-29得票数 0

回答已采纳

1回答

将小枝连接到kafka开始使用docker组合进行本地主机的开发。

java、spring、spring-boot、docker、apache-kafka

- KAFKA_CFG_INTER_BROKER_LISTENER_NAME=INSIDE - ALLOW_PLAINTEXT_LISTENER- '9000:9000' - KAFKA_BROKERCONNECT=kafka-broker-1:9092,kafka-broker-2:9093dep

浏览 5提问于2020-04-06得票数 3

1回答

Kafka KO (可能找不到代理)：尝试连接的次数

apache-kafka

在我的应用程序中，我必须处理卡夫卡不可用的情况。在这种情况下(我通过停止Kafka服务器自愿提供)，我的客户多次尝试连接6分钟。我怎样才能改变这6分钟的尝试？是否有更改6分钟等待时间的属性？谢谢

浏览 11提问于2022-08-09得票数 0

1回答

利用IP地址访问远程主机中的Kafka

spring-boot、apache-kafka、docker-compose、spring-kafka

: networks: restart: unless-stopped: kafka:29092networks: driver: bridge 我需要的是向我的网络公开这个由Spring应用程序访问的IP机器。spring.kafka</

浏览 1提问于2020-12-07得票数 3

1回答

春季引导卡夫卡不起作用-消费者不接收消息

java、spring-boot、apache-kafka

我试图运行一个简单的Spring应用程序，但我无法使它工作。root: ERROR com.memorynotfound: DEBUG private String bootstrapServersreturn f

浏览 3提问于2019-04-01得票数 1

回答已采纳

1回答

Spring cloud stream:同一个应用中的两个不同的Kafkas

spring、spring-cloud、spring-cloud-stream

我正在尝试在同一个应用程序中使用两种不同的Kafka。当我只有一个Kafka时，我的application.yml是： spring: stream: binder:brokers: kafka_broker01 headers: type binders:some-bind

浏览 35提问于2019-02-21得票数 0

回答已采纳

1回答

在Docker-compose中使用Kafka运行Spring* Boot应用程序*

java、spring、docker、apache-kafka、docker-compose

我有下一个属性： spring.kafka.bootstrap-servers=127.0.0.1:29092 environment: KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181 KAFKA_ADVERTISED_LISTENERS:

浏览 12提问于2021-10-30得票数 0

回答已采纳

1回答

Kafka未连接到下面的问题

java、spring、spring-boot、apache-kafka、kafka-consumer-api

=localhost:9092spring.kafka.consumer.auto-offset-reset=earliestspring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer spring.kafka.consume

浏览 7提问于2021-09-09得票数 1

2回答

引导代理不用于从主题中使用

java、apache-kafka、spring-kafka

一个简单的spring kafka，它使用的是网络集群上的一个主题：无法建立与节点-1 (localhost/127.0.0.1:9092)断开连接的引导代理本地主机:9092 (id：-1齿条谜题： <dependency> &

浏览 7提问于2021-06-08得票数 1

回答已采纳

1回答

spring-kafka不能使用kafka-cluster

spring-kafka、kafka-cluster

我已经配置了3个kafka集群，我正在尝试使用spring-kafka。但是当我杀死kafka时，我不能发送其他消息到队列中。Kafka版本2.0.0 spring-kafka版本2.0.1 kafka-topics.sh --describe -zookeeper=zoo1:2181打印 KAFKA_SWARM_TESTLeader: 2 Replicas: 1,2 Isr: 2,1 spr

浏览 21提问于2019-08-26得票数 3

2回答

Spring Cloud Stream Kafka无法连接

docker、apache-kafka、spring-cloud-stream、spring-cloud-stream-binder-kafka

: environment: KAFKA_ZOOKEEPER_CONNECT: zookeeper:=event spring</em

浏览 106提问于2020-05-07得票数 0

回答已采纳

1回答

Kafka Streams broker连接超时设置

apache-kafka、apache-kafka-streams

我们使用的是kafka-streams 2.3.1，我刚刚注意到，如果broker宕机，streams应用程序似乎满足于尝试永远保持连接。new KafkaStreams(createTopology(), properties()).start() o.apache.kafka.clients.NetworkClient - [AdminClientclientId=test] Connection to node -1 (broker/127.0.0.1:9092) could not be establi

浏览 41提问于2019-12-19得票数 2

1回答

Kafka未能更新元数据

java、apache-kafka、kafka-consumer-api、kafka-producer-api、spring-kafka

卡夫卡属性spring.kafka.producer.batch-size=1000spring.kafka.producer.linger.ms=10spring.kaf

浏览 7提问于2017-10-25得票数 4

1回答

Flink 1.9.1无法再连接到Azure事件中心

java、azure、apache-kafka、apache-flink、azure-eventhub

我在几个spring引导应用程序中也有同样的问题，但是当我升级到SpringBoot2.2.2时，这个问题得到了解决，SpringBoot2.2.2也将Kafka客户端和Kafka依赖项更新为2.3.1我试图更新Flink的kafka依赖，但没有成功。我还提交了一个问题 2020-01-10 19:36:30,364 org.apache.kafka.clients.NetworkClient -消费客户端=消费者-1，groupId=****Bootstrap broker

浏览 0提问于2020-01-10得票数 1

回答已采纳

点击加载更多