我有一个Spring引导项目，它具有使用kafka进行日志记录的依赖项。我无法摆脱这种依赖关系，因为我的逻辑需要依赖关系中的代码 我想在不运行kafka的情况下在本地启动该应用程序，这样我就可以测试我的简单数据库查找代码。我已尝试禁用自动配置 spring.autoconfigure.exclude=org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration应用程序启动，但spring拒绝打开侦
浏览 37提问于2020-04-15得票数 2
1回答
我正试图连接到Kafka broker，后者执行双向SSL/TLS来验证和授权客户端。我已经通过正确的权限创建了证书签名，并存储在我的本地用户目录中。我在用我的application.propertiessprin
浏览 5提问于2022-08-29得票数 0
回答已采纳
--- [nio-8080-exec-4] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-consumer-test-group-spring-boot--- [nio-8080-exec-4] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-consumer-test-group-spring-boot</e
浏览 108提问于2021-10-09得票数 1
我在Kubernetes集群中有一个kafka代理和一个spring引导应用程序。他们在自己的集装箱上奔跑。---kind: Deployment labels: name: kafka-br
浏览 25提问于2022-07-07得票数 0
brokerList = broker.getBrokersAsString(); }我用：我猜想依赖关系不一致在这里占据了位置，但是，这是奇怪的，因为我相信Spring父母可以实现依赖兼容性。<parent>
<groupId>org.sprin
浏览 5提问于2020-06-19得票数 0
回答已采纳
1回答
卡夫卡消费者无法连接时快速失败
、、、、
为了我自己的目的，如果Kafka消费者无法连接到代理，我需要Spring应用程序停止。我的意思是，当卡夫卡消费者试图汇集信息时，我们可以看到以下日志：当没有话题或经纪人的时候，这是标准的行为。因此，应用程序将不会停止。但我需要。我试图添加以下属性，但这不是工作：
spring.kafka
浏览 5提问于2021-02-11得票数 0
回答已采纳
我刚接触docker，在Docker容器中运行Kafka代理时遇到了问题。我和kafka开发了spring boot应用程序，生产者和消费者在同一个应用程序中。Broker may not be available.Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
我使用了spring boot 2.4.2和ka
浏览 237提问于2021-02-21得票数 0
我正在尝试将我的spring boot应用程序连接到Kafka主题，但它看起来spring正在尝试连接到localhost而不是docker ip，因为我在windows上使用docker。这是spring上的Kafka配置类： @Configurationpublic ProducerFactory<String,Stringenvironment:
浏览 30提问于2020-07-28得票数 1
1回答
我有一个接口程序-E29，其中我运行了动物园管理员、Kafka、Kafka Connect和KafDrop，问题是，当我在本地运行时，我可以从我的Spring Boot<code>E 29</code>应用程序连接来使用一些主题消息。我需要的是在Linux机器上运行相同的配置，并能够以同样的方式从Spring应用程序连接。当在Linux机器上远程运行它时，一切似乎都运行正常，但是当我尝试从Spring
浏览 1提问于2020-12-07得票数 3
当Kafka broker变得不可用时，我的spring boot 2.1.5消费者应用程序宕机，异常如下。它使用的是spring-kafka 2.2.6。我需要我的应用程序保持运行，并在kafka broker回来后继续消费。org.springframework.context.ApplicationContextException: Failed to start bean
'org.springframework.kafka<
浏览 32提问于2019-12-12得票数 1
回答已采纳
我需要升级kafka broker到版本2.x，所有的模块都很好，只有一个组件。它使用的是spring cloud stream和kafka绑定器版本2.0.2。在内部，它似乎在使用kafka-client 1.0.2此外，spring-kafka页面告诉您参考kafka以获得客户端-代理兼容性但是我发现了这个页面，它显示，无论<
浏览 12提问于2021-02-19得票数 1
回答已采纳
我有一个基本的spring启动服务，它通过Kafka发送消息。 当kafka连接断开时，spring boot actuator会将kafka活页夹的状态显示为DOWN，将整体状态显示为DOWN。但是，Readiness和Liveness都是UP。然而，我希望将卡夫卡粘合剂的停机状态传播到Readiness指示器。也就是说，如果kafka启动，我希望localhost:8080/actuator/
浏览 8提问于2020-10-01得票数 1
- '9000:9000' - KAFKA_BROKERCONNECT=kafka-broker-1:9092,kafka-broker-2:9093depends_on: - kafka-broker-2
然后，我尝试将我的Spring命令行应用程序连接到Kafka<
浏览 5提问于2020-04-06得票数 3
at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$OffsetCommitResponseHandler.handle(ConsumerCoordinator.java:787) at org.apache.kafka.clients.consum
浏览 0提问于2018-07-12得票数 0
我们使用的是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 b
浏览 41提问于2019-12-19得票数 2
1回答
Java 8，Azure事件中心
2020-01-10 19:36:30,364 org.apache.kaf
浏览 0提问于2020-01-10得票数 1
回答已采纳
: environment: KAFKA_ZOOKEEPER_CONNECT: zookeeper:=event
spring</em
浏览 106提问于2020-05-07得票数 0
回答已采纳
我在日志中得到了以下内容
我怀疑嵌入式Spring代理背后的想法是只允许本地内存集成测试，而不是向外界公开嵌入式JMS代理。
浏览 2提问于2016-12-28得票数 5
回答已采纳
ActiveMQ与aplication.yaml之间的连接配置有什么不同吗？spring.artemis.mode=nativespring.artemis.port=9876spring.activemq.broker-url<dependency>
<groupId>org.springframework.boot</grou
浏览 11提问于2022-06-07得票数 0
回答已采纳
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号