经过几个小时的努力为这个问题找到解决方案，我决定把它张贴在这里。我有以下的码头-写作，它开始动物园，2卡夫卡经纪人和kafdrop kafka-net: - kafka-broker-1然后，我尝试将我<e
浏览 5提问于2020-04-06得票数 3
1回答
我希望在一个只允许上述应用程序运行的环境中部署一个spring引导应用程序。我的应用程序将是卡夫卡的生产者和消费者。是否有一种方法可以在启动时运行内存实例，用于测试以外的目的？或者，是否有一种方法来启动一个春季引导应用程序，如果它不能连接到卡夫卡作为一个生产者和消费者？
编辑:这是一个临时的解决方案，直到我们能够在这个环境中部署Kafka。该<e
浏览 9提问于2020-09-09得票数 2
2回答
我试图连接我的卡夫卡容器和我的码头形象所有运行在本地，不想创建一个容器与卡夫卡和动物园管理员的形象。could not read message dial tcp 172.21.0.3:9092: i/o timeout
在卡夫卡日志中，它显示了Connection request from old client /172.18.0.1:56350; w
浏览 16提问于2021-12-07得票数 3
2回答
如果我的spring引导应用程序无法连接到kafka broker，我想让它在start上失败。我的应用程序只向主题发布消息。我将这一行添加到我的属性文件中，但是到目前为止，spring.kafka.admin.fail-fast=true没有任何进展。
浏览 0提问于2019-03-15得票数 2
回答已采纳
1回答
卡夫卡消费者无法连接时快速失败
、、、、
为了我自己的目的，如果Kafka消费者无法连接到代理，我需要Spring应用程序停止。我的意思是，当卡夫卡消费者试图汇集信息时，我们可以看到以下日志：当没有话题或经纪人的
浏览 5提问于2021-02-11得票数 0
回答已采纳
我正在尝试将我的spring boot应用程序连接到Kafka主题，但它看起来spring正在尝试连接到localhost而不是docker ip，因为我在windows上使用docker。这是spring上的Kafka配置类： @Configurationpublic ProducerFactory<St
浏览 30提问于2020-07-28得票数 1
1回答
我一直在做春云侦探，把痕迹推到zipkin，我们在spring-cloud-starter-stream-kafka和spring-cloud-sleuth-stream的帮助下把痕迹推到卡夫卡。下面是我添加到应用程序中的依赖项
compile group: 'org.springframework.cloud', name: 'spring-cloud-starter-sleuth', ver
浏览 1提问于2019-12-19得票数 0
2回答
在同一个网络中有客户端、卡夫卡和动物园管理员，我试图用SERVICE_NAME:PORT从客户端连接到卡夫卡，但是我犯了个错误。
我知道我可以很容易地使用服务名称在同一个网络中通信容器，但是我不明白为什么它不能工作。我的客户试图与卡夫卡沟通的名字是driver-servic
浏览 11提问于2022-07-24得票数 0
回答已采纳
在启动该服务时，它使用SASL KERBEROS连接到代理，并出现其他代理的以下错误(SASL SCRAM)。当我们在应用程序YAML中使用SALS SCRAM连接到一个代理时，它连接时没有任何错误
========================================================(SaslClientAuthenticator.java:296)的org.apache.kafka.common.security.authenticator.SaslClie
浏览 22提问于2021-06-09得票数 0
我有一个Spring引导项目，它具有使用kafka进行日志记录的依赖项。我无法摆脱这种依赖关系，因为我的逻辑需要依赖关系中的代码 我想在不运行kafka的情况下在本地启动该应用程序，这样我就可以测试我的简单数据库查找代码。我已尝试禁用自动配置 spring.autoconfi
浏览 37提问于2020-04-15得票数 2
1回答
我试图运行一个简单的Spring应用程序，但我无法使它工作。我已经学习了各种教程，现在我正在实现，但是当我启动应用程序时，会发生这样的情况：我可以在控制台中写东西，但是使用者没有收到任何消息。在启动应用程序之前，我运行和
.publ
浏览 3提问于2019-04-01得票数 1
回答已采纳
1回答
我正尝试在亚马逊网络服务的K8s 1.6集群中使用Istio。我有一个Kafka pod/service运行旧的方式，有一个没有IP的" kafka-zk-broker-kafka.dev“服务，所以Kafka -zk-broker-kafka.dev服务(我在dev命名空间中)解析为我的3个Kafk
浏览 11提问于2017-07-27得票数 1
1回答
我正在尝试使用Kafka作为消息传递系统来构建我的第一个应用程序，但是我在运行它时遇到了一些问题。我使用动物园管理员和来自wurstmeister的Kafka与此的码头图片。: "toAll:1:1"docker-compose 为我提供了以下输出：
kafka_1 | [2022-06-13
浏览 26提问于2022-06-13得票数 0
回答已采纳
1回答
我有一个接口程序-E29，其中我运行了动物园管理员、Kafka、Kafka Connect和KafDrop，问题是，当我在本地运行时，我可以从我的Spring Boot<code>E 29</code>我需要的是在Linux机器上运行相同的配置，并能够以同样的方式从Spring应用程序连接。当在Linux机器上远
浏览 1提问于2020-12-07得票数 3
我有一个Kafka broker运行在一个多VM环境中(私有云-与我们自己的Kubernetes集群-4节点集群)。我已经创建了一个spring引导应用程序，它的发行者必须发布一条消息到Kafka broker内部的Kafka主题。我让两个容器(Kafka broker & spring引导应用
浏览 0提问于2020-08-18得票数 2
问题是，尽管我的生产者有时会工作，但消费者总是给我超时错误，或者它只是在无休止的循环中尝试连接到kafka，即使tought也工作得很好。即使我把所有的代码(消费者和生产者)和kafka放在同一台机器上(认为mabye windows是问题的一部分)，这种奇怪的行为仍在继续。我试着在kafka内置的生产者控制台中发送消息，但我的消费者似乎仍然不能成功订阅主题并获得消息。当我测试<e
浏览 56提问于2019-06-19得票数 3
在我的应用程序中，我必须处理卡夫卡不可用的情况。在这种情况下(我通过停止Kafka服务器自愿提供)，我的客户多次尝试连接6分钟。我怎样才能改变这6分钟的尝试？是否有更改6分钟等待时间的属性？谢谢
浏览 11提问于2022-08-09得票数 0
我通过"KAFKA.BOOTSTRAP.SERVERS: broker:19092“给了zipkin与正常运行的neo4j相同的地址。Apiimage: confluentinc/cp-kafka:latest
hostname“被推送到kafka，因为我</em
浏览 70提问于2021-07-19得票数 0
当Kafka broker变得不可用时，我的spring boot 2.1.5消费者应用程序宕机，异常如下。它使用的是spring-kafka 2.2.6。我需要我的应用程序保持运行，并在kafka broker回来后继续消费。org.springframework.context.ApplicationContextExcep
浏览 32提问于2019-12-12得票数 1
回答已采纳
云服务器
ICP备案
对象存储
云直播
实时音视频
腾讯云开发者
