Spring Kafka中断开broker检测
是指在使用Spring Kafka框架时，检测到与Kafka broker之间的连接中断的机制。
Spring Kafka是一个基于Spring框架的开源项目，用于简化在Java应用程序中使用Apache Kafka的开发。它提供了一组易于使用的API，使开发人员能够轻松地与Kafka进行交互。
在使用Spring Kafka时，可以配置一个用于检测与Kafka broker之间连接中断的机制。当检测到连接中断时，可以采取一些处理措施，例如重新连接到Kafka broker或者进行一些错误处理。
以下是一些可能的处理措施：
- 重新连接到Kafka broker：当检测到连接中断时，可以尝试重新连接到Kafka broker，以恢复与Kafka的通信。可以使用Spring Kafka提供的自动重连机制，或者自定义实现重新连接的逻辑。
- 错误处理：当连接中断时，可以根据具体情况进行错误处理。例如，可以记录错误日志、发送警报通知、进行回滚操作等。
- 降级处理：当连接中断时，可以切换到备用的数据源或者使用缓存数据，以保证系统的正常运行。可以使用Spring Kafka提供的降级机制，或者自定义实现降级的逻辑。
Spring Kafka提供了一些配置选项，用于配置中断连接检测的相关参数。例如，可以配置连接超时时间、心跳间隔、最大重试次数等。
推荐的腾讯云相关产品：腾讯云消息队列 CMQ、腾讯云云服务器 CVM、腾讯云云数据库 CDB、腾讯云云原生容器引擎 TKE。
腾讯云产品介绍链接地址：
- 腾讯云消息队列 CMQ：https://cloud.tencent.com/product/cmq
- 腾讯云云服务器 CVM：https://cloud.tencent.com/product/cvm
- 腾讯云云数据库 CDB：https://cloud.tencent.com/product/cdb
- 腾讯云云原生容器引擎 TKE：https://cloud.tencent.com/product/tke
相关·内容
我让这个方法工作得很好。通过这种方法，我能够从特定的Kafka主题中抓取消息。 public List<MessageResponseDTO> getMessagesFromTopic(String topicName, Properties properties) {
List<MessageResponseDTO> messages = new ArrayList<>();
try (KafkaConsumer<String, String> consumer = new KafkaConsumer<>(prop
浏览 108提问于2021-10-09得票数 1
目前正在遵循https://github.com/openzipkin/zipkin快速入门，用于zipkin和kafka的docker启动。我设置了一个docker-compose来启动几个服务: kafka、zookeeper、neo4j和zipkin。我通过"KAFKA.BOOTSTRAP.SERVERS: broker:19092“给了zipkin与正常运行的neo4j相同的地址。 zipkin:
image: ghcr.io/openzipkin/zipkin:${TAG:-latest}
container_name: zipkin
depends_on:
- bro
浏览 70提问于2021-07-19得票数 0
2回答
在同一个网络中有客户端、卡夫卡和动物园管理员，我试图用SERVICE_NAME:PORT从客户端连接到卡夫卡，但是
driver-service-container | 2022-07-24 09:00:05.076 WARN 1 --- [| adminclient-1] org.apache.kafka.clients.NetworkClient : [AdminClient clientId=adminclient-1] Connection to node 1 (localhost/127.0.0.1:9092) could not be established. Broker may
浏览 11提问于2022-07-24得票数 0
回答已采纳
1回答
我有一个接口程序-E29，其中我运行了动物园管理员、Kafka、Kafka Connect和KafDrop，问题是，当我在本地运行时，我可以从我的Spring Boot<code>E 29</code>应用程序连接来使用一些主题消息。
我需要的是在Linux机器上运行相同的配置，并能够以同样的方式从Spring应用程序连接。
当在Linux机器上远程运行它时，一切似乎都运行正常，但是当我尝试从Spring应用程序连接时，我收到了一些错误，表明连接中有问题。
我会试着一步一步地解释，看看是否有人能对此“指指点点”：
docker-compose.yml：
version:
浏览 1提问于2020-12-07得票数 3
我正在尝试在同一个应用程序中使用两种不同的Kafka。 当我只有一个Kafka时，我的application.yml是： spring:
cloud:
stream:
kafka:
binder:
brokers: kafka_broker01
zkNodes: kafka_broker01
headers: type
binders:
some-binder:
type: kafka
inheritEnv
浏览 35提问于2019-02-21得票数 0
回答已采纳
我有应用程序(kafka客户端)。我有下一个属性： spring.kafka.bootstrap-servers=127.0.0.1:29092
spring.kafka.consumer.group-id=mc3 我在Docker中有kafka -compose： kafka:
image: confluentinc/cp-kafka:latest
depends_on:
- zookeeper
ports:
- 29092:29092
environment:
KAFKA_BROKER_ID: 1
KAFKA_ZOOKEEPER_CONNE
浏览 12提问于2021-10-30得票数 0
回答已采纳
1回答
Kafka未连接到下面的问题
、、、、
2021-09-09 21:42:40.039 WARN 14636 --- [ntainer#0-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-mygroup-1, groupId=mygroup] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2021-09-09 21:42:40.039 WARN 14636 ---
浏览 7提问于2021-09-09得票数 1
我已经配置了3个kafka集群，我正在尝试使用spring-kafka。但是当我杀死kafka时，我不能发送其他消息到队列中。 Kafka版本2.0.0 spring-kafka版本2.0.1 kafka-topics.sh --describe -zookeeper=zoo1:2181打印 KAFKA_SWARM_TEST PartitionCount:1 ReplicationFactor:2 Configs:
Topic: KAFKA_SWARM_TEST Partition: 0 Leader: 2 Replicas: 1,2
浏览 21提问于2019-08-26得票数 3
我正在使用这个docker compose：
version: '2'
services:
zookeeper:
image: confluentinc/cp-zookeeper:4.1.1
hostname: zookeeper
ports:
- "32181:32181"
environment:
ZOOKEEPER_CLIENT_PORT: 32181
ZOOKEEPER_TICK_TIME: 2000
ZOOKEEPER_SYNC_LIMIT: 2
kafka:
浏览 106提问于2020-05-07得票数 0
回答已采纳
我们使用的是kafka-streams 2.3.1，我刚刚注意到，如果broker宕机，streams应用程序似乎满足于尝试永远保持连接。 new KafkaStreams(createTopology(), properties()).start() o.apache.kafka.clients.NetworkClient - [AdminClient clientId=test] Connection to node -1 (broker/127.0.0.1:9092) could not be established. Broker may not be available. 在这种
浏览 41提问于2019-12-19得票数 2
我在Kubernetes集群中有一个kafka代理和一个spring引导应用程序。他们在自己的集装箱上奔跑。
spring引导应用程序是消息生成器。它需要访问kafkabroker来发送消息。但它无法通过提供卡夫卡的服务名称:生产者bootstrap.servers中的端口来访问卡夫卡经纪人。
任何帮助都将不胜感激。
yaml中的Zookeper和KafkaBroker配置：
---
apiVersion: v1
kind: Service
metadata:
labels:
app: zookeeper-service
name: zookeeper-service
na
浏览 25提问于2022-07-07得票数 0
当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.config.internalKafkaListenerEndpointRegistry';
nested exception is
浏览 32提问于2019-12-12得票数 1
回答已采纳
我需要升级kafka broker到版本2.x，所有的模块都很好，只有一个组件。它使用的是spring cloud stream和kafka绑定器版本2.0.2。在内部，它似乎在使用kafka-client 1.0.2
根据kafka兼容性矩阵，此客户端应与所有较新的kafka版本兼容
此外，spring-kafka页面告诉您参考kafka以获得客户端-代理兼容性
但是我发现了这个页面，它显示，无论Kafka客户端是什么，spring cloud只与Kafka broker版本1.1.x、1.0.x、0.11.0.x兼容
这把我搞糊涂了，有没有人能说清楚兼容性是什么？
浏览 12提问于2021-02-19得票数 1
回答已采纳
我有一个Kafka broker运行在一个多VM环境中(私有云-与我们自己的Kubernetes集群-4节点集群)。
我已经创建了一个spring引导应用程序，它的发行者必须发布一条消息到Kafka broker内部的Kafka主题。我让两个容器(Kafka broker & spring引导应用程序)运行在同一个Kubernetes集群中。
我无法访问卡夫卡代理(运行在同一个k8s集群中)，无法提供Kafka的服务名称:发布服务器的bootstrap.servers中的端口id
Spring的发行者配置：
props.put(ProducerConfig.BOOTSTRAP_SER
浏览 0提问于2020-08-18得票数 2
我正在尝试将我的spring boot应用程序连接到Kafka主题，但它看起来spring正在尝试连接到localhost而不是docker ip，因为我在windows上使用docker。这是spring上的Kafka配置类： @Configuration
public class KafkaConfig {
@Bean
public ProducerFactory<String,String> producerFactory()
{
Map<String,Object> config = new HashMap<>();
confi
浏览 30提问于2020-07-28得票数 1
1回答
消费者有时不能工作，有时不能工作，不能解决问题。
spring boot - 1.5.21.release
kafka client - 0.11.0.0
kafka servers - IBM event stream service on cloud.
应用程序属性：
#Producer
spring.kafka.template.default-topic=distitopic
spring.kafka.producer.client-id=event-streams-kafka
spring.kafka.producer.key-serializer=org.apache.kafka.
浏览 25提问于2019-07-08得票数 1
我们在application.YAML中配置了两个Kafka代理，一个使用SASL KERBEROS，另一个使用SASL SCRAM。在启动该服务时，它使用SASL KERBEROS连接到代理，并出现其他代理的以下错误(SASL SCRAM)。当我们在应用程序YAML中使用SALS SCRAM连接到一个代理时，它连接时没有任何错误
==============================================================================================将SASL客户端状态设置为RECEIVE_APIVERSIONS_RESPON
浏览 22提问于2021-06-09得票数 0
我很难开始嵌入式卡夫卡的集成测试。显示此错误：
创建名为“embeddedKafka”的bean的org.springframework.beans.factory.BeanCreationException:错误: init方法调用失败；嵌套异常为java.lang.NoClassDefFoundError: org/apache/zoo门将/client/ZKClientConfig
这是我的最小样本。只要我需要更多的Spring，我就需要使用@ExtendWith(SpringExtension.class)。
@ExtendWith(SpringExtension.class)
@E
浏览 5提问于2020-06-19得票数 0
回答已采纳
我需要使用kafka stream 2.2库中的功能，然而，我的底层kafka broker版本不是2.2。
可以使用kafka stream 2.2版本的库来对抗kafka broker 2.12-1.1.1吗？
浏览 1提问于2019-06-13得票数 1
1回答
@RunWith(SpringRunner.class) @SpringBootTest @DirtiesContext @EmbeddedKafka(分区= 1，主题= {EmbeddedKafkaIntegrationTest.TEST_TOPIC}，bootstrapServersProperty =“Spring.kafka.bootstra-Servers”) @ActiveProfiles("test")公共类EmbeddedKafkaIntegrationTest {
static final String TEST_TOPIC = "MERCHANT-S
浏览 23提问于2022-10-17得票数 0
我有一个Kafka消费者。如果消费者无法阅读任何消息，我需要将其发送到Dead Letter主题。我使用的是Spring cloud Kafka流，我在如下配置中启用了DLQ。 spring:
cloud:
stream:
function:
definition: myConsumer
kafka:
binder:
consumer-properties:
auto.offset.reset: earliest
bindings:
myCon
浏览 12提问于2021-02-03得票数 0
3回答
我有一个与Kafka通信的spring引导应用程序。
我通过注入环境变量在生产中配置此应用程序。
对于kafka，我可以使用环境变量配置大多数东西--引导服务器、ssl信任存储位置、ssl信任存储密码、组id、主题，例如：
SPRING_KAFKA_SSL_TRUSTSTORE-LOCATION: "file:/opt/app/jks/totally_real_file.jks"
SPRING_KAFKA_SSL_TRUSTSTORE-PASSWORD: "hunter2"
因为我可以使用环境变量配置ssl密钥存储库和密码，所以我假设可以配置SSL协议和安全协议
浏览 2提问于2018-07-13得票数 3
1回答
我一直在做春云侦探，把痕迹推到zipkin，我们在spring-cloud-starter-stream-kafka和spring-cloud-sleuth-stream的帮助下把痕迹推到卡夫卡。
下面是我添加到应用程序中的依赖项
compile group: 'org.springframework.cloud', name: 'spring-cloud-starter-sleuth', version: '1.0.0.RELEASE'
compile group: 'org.springframework.cloud', na
浏览 1提问于2019-12-19得票数 0
我正试图在本地机器上从kubernetes之外访问kafka。我正在使用spring应用程序来产生一个主题的事件。这是我的kafka部署文件：
kind: Deployment
metadata:
name: kafka-broker0
labels:
app: kafka
spec:
replicas: 2
selector:
matchLabels:
app: kafka
id: "0"
template:
metadata:
labels:
app: kafka
浏览 2提问于2020-09-26得票数 1
我看到了不同的行为。共提供3种不同的服务
第一个服务将从Solace队列中侦听，并将其生成到kafka Top-1(其中启用了事务)
“第二服务”将从上面的kafka主题-1中收听，并将其写入另一个kafka主题-2(在该主题中，我们没有手动提交、允许生成到其他主题的事务、自动提交偏移量设置为false & isolation.level设置为read_commited)
第三，服务将从KafkaTop-2中侦听，并将其写回Solace队列(在该队列中，我们没有手动提交，自动提交偏移量为false & isolation.level设置为read_commited)
浏览 0提问于2019-03-29得票数 1
回答已采纳
1回答
当我使用http协议kafka运行时，我对kafka有一个问题，没有任何问题。
但是在将协议从http升级到https之后
升级后，所有服务都返回相同的错误。
2021-10-28 23:16:26.367 WARN 1 --- [ad | producer-1] org.apache.kafka.clients.NetworkClient : [Producer clientId=producer-1] Connection to node 1 (/206.189.178.228:9092) could not be established. Broker may not be ava
浏览 1提问于2021-10-28得票数 0
回答已采纳
1回答
卡夫卡消费者无法连接时快速失败
、、、、
为了我自己的目的，如果Kafka消费者无法连接到代理，我需要Spring应用程序停止。我的意思是，当卡夫卡消费者试图汇集信息时，我们可以看到以下日志：
[Consumer clientId=consumer-ddddd-1, groupId=ddddd] Bootstrap broker localhost:9094 (id: -1 rack: null) disconnected
[Consumer clientId=consumer-ddddd-1, groupId=ddddd] Connection to node -1 (localhost/127.0.0.1:9094) could
浏览 5提问于2021-02-11得票数 0
回答已采纳
我遇到了一个问题与弹簧启动卡夫卡对接，尝试了所有提到的东西在下面的链接，但问题仍然存在。
把我的船坞-Compose.yml
version: '2'
services:
zookeeper:
image: wurstmeister/zookeeper
container_name: zookeeper
ports:
- "2181:2181"
kafka:
image: wurstmeister/kafka
container_name: kafka
ports:
- "9092
浏览 2提问于2020-11-03得票数 4
我有一个关于Kubernetes中的Kafka的问题，特别是自动缩放...
假设我在Kubernetes的3个Pod中有3个Kafka Broker，有一个带有5个分区(P1，P2，P3，P4，P5)的TopicA，复制因子是3，所有的Broker都有他们的持久卷，我在Kubernetes中配置了自动扩展，所以如果它检测到Kafka Pods中的%80CPU/内存使用率，它将为Kafka Broker启动额外的Pod...
如果我没有完全错的话，Kafka会检测到Zookeeper上的额外实例，并可以移动分区(所以假设P1，P2在Broker1和P3，P4在Broker2，P5在Broker3
浏览 5提问于2019-11-06得票数 2
1回答
在Kubernetes集群中，我创建了指向Kafka集群的端点。成功创建终结点。
名字- kafka
端点-X.X:9092
在Spring应用程序的部署yaml中，我保持了环境变量BROKER_IP。对于这个环境变量，我已经指出：
env:
- name: BROKER_IP
value: kafka
POD处于错误状态。在我的bootstrap-server中，我得到的是kafka，而不是创建的实际端点。有什么想法吗？
UPDATE --刚刚试用了kafka:9092，它成功了。因此，想知道端点是否只映射到IP而不是端口？我的理解正确吗？
浏览 0提问于2019-08-19得票数 1
1回答
如何与卡夫卡对接-制作弹簧靴？
、、、、
执行工作正常，但我想我遗漏了一些东西，因为当我使用REST时，它将显示：
(/127.0.0.1:9092)不能建立。经纪人可能不可用
你可以在下面看到这个。顺便说一句，我是道克和卡夫卡的新手。
我不能发送或获取数据到/ get /POST/PUT/DELETE，因为我使用Docker。
创建此设置时的参考：
//docker-compose.yaml
version: '3'
services:
#----------------------------------------------------------------
product
浏览 16提问于2022-05-04得票数 1
回答已采纳
我刚接触docker，在Docker容器中运行Kafka代理时遇到了问题。我和kafka开发了spring boot应用程序，生产者和消费者在同一个应用程序中。应用程序在没有docker的情况下成功运行，但当我尝试通过主机上的docker容器运行它时，会出现以下错误：
org.apache.kafka.clients.NetworkClient : [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not
浏览 237提问于2021-02-21得票数 0
我不确定我是否理解了Spring Cloud Data Flow (SCDF)和Apache Kafka Broker(及其相关的Zookeeper)之间的关系。
我阅读了一些文档，并观看了一个关于Spring Cloud数据流(SCDF)的网络研讨会。我了解不同的绑定选项(RabbitMQ，Kafka，...)用于此框架中不同微服务之间的通信。
我找到了很多关于如何使用Kafka的信息，但不知道在哪里运行/操作它。我的假设是否正确，即您必须独立于SCDF安装/管理/操作Kafka代理(+ Zookeeper)？SCDF“只是”使用Kafka代理进行内部通信，以及-可选的-用于微服务内的业务逻
浏览 0提问于2017-10-25得票数 1
以下是我迄今为止在Server上成功完成的工作
我已经成功地在我的本地部署了SCDF服务器，并且我也使用了Kafka和Zoo门将配置参数，即
spring-cloud-dataflow-server-local-1.3.0.RELEASE.jar --spring.cloud.dataflow.applicationProperties.stream.spring.cloud.stream.kafka.binder.brokers=localhost:9092 --spring.cloud.dataflow.applicationProperties.stream.spring.c
浏览 2提问于2018-02-12得票数 0
回答已采纳
我希望将多个数据库的更改聚合到一个数据库中，因此我想在每个数据库旁边运行一个Debezium连接器和一个Kafka服务器/broker，并使用Kafka接收器连接器从所有的Kafka中使用，将其写入一个数据库。
问题是，我能否同时使用Kafka接收器连接器的一个实例，使用多个独立的Kafka代理(而不是集群)。
浏览 0提问于2021-08-29得票数 0
回答已采纳
我使用Spring 1.5.6 version、Spring 1.3.2.RELEASE和Spring ( Kafka ) 1.2.0.RELEASE，Kafka版本为0.10.1.1。我试图将其配置为使用两个启用ssl的代理，但最后得到了一个重复的警告消息序列(每个代理一个)，如下所示：
Bootstrap broker broker1:9993 disconnected
Bootstrap broker broker2:9993 disconnected
在我的配置中，我有(仅包括这里包含的相关部分)：
spring:
cloud:
stream:
浏览 2提问于2017-10-18得票数 0
回答已采纳
我是spring cloud的新手，我正在寻找使用kafka broker的spring cloud stream的任何简单完整的示例。
浏览 5提问于2017-03-13得票数 0
2回答
如果我的spring引导应用程序无法连接到kafka broker，我想让它在start上失败。我的应用程序只向主题发布消息。我将这一行添加到我的属性文件中，但是到目前为止，spring.kafka.admin.fail-fast=true没有任何进展。
浏览 0提问于2019-03-15得票数 2
回答已采纳
1回答
对于我的卡夫卡批次消费者，有两种情况我想要处理。
侦听器接收记录之前发生的反序列化异常。重新尝试这些没有多大意义，只需直接发送到DLQ。
侦听器中发生的异常。由于我正在对批处理应用一些流操作(过滤和分组等)，因此很难确切地知道批处理中哪些记录失败。因此，对我来说，只要重试整个批，并且如果达到重试极限，将整个批处理发送到DLQ，这是更简单和可以接受的。
编辑后反馈
我已经成功地使用了ListenerContainerCustomizer来解决场景2。
现在，我仍然需要处理场景1(反序列化异常)。我尝试过使用failedDeserializationFunction，如这
浏览 1提问于2021-06-29得票数 0
1回答
我们正在开发spring引导应用程序，我们已经实现了MSK AWS (Kafka)，生产者和消费者的通信正在按预期的方式工作，但是一旦我检查了日志，它就会发出如下警告。
Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available
Spring启动yml配置文件
spring:
cloud:
config:
enabled: true
application:
name: my-service
ka
浏览 12提问于2022-08-23得票数 0
回答已采纳
1回答
在使用kafka时，我遇到了断断续续的两个网络相关错误。
1. Error in fetch kafka.server.replicafetcherthread$fetchrequest connection to broker was disconnected before the reponse was read
2. Error in fetch kafka.server.replicafetcherthread$fetchrequest Connection to broker1 (id: 1 rack: null) failed
配置环境
Brokers: 5/ server.p
浏览 4提问于2019-10-24得票数 0
1回答
我正在开发一个简单的应用程序，使用spring boot和Kafka将对象保存到Kafka主题中，然后有一个消费者会监听并将该记录添加到内存数据库中。经过下面的配置，Kafka和spring boot都可以工作了，但是对Kafka的API调用将会挂起一段时间，并且Kafka主题中也不会有任何消息。
我遵循了下面的教程
但我稍微改变了一下我的服务。
package com.dilshan.shoppingcart.cart;
import org.springframework.stereotype.Service;
import java.io.IOException;
import
浏览 12提问于2020-02-18得票数 0
我正在尝试将一些非关键数据推送到Kafka中，但我仍然希望应用程序在没有Kafka的情况下运行。然而，我的Spring Boot (使用spring-kafka 2.7.2)现在不能正常启动，它在一个循环中：
[AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
基本上，这会阻止对我的应用程序的所有http请求，因为我猜只有当它连接到Kafka时，启动过程才能完成。大概
浏览 16提问于2021-12-02得票数 0
我们在HDP集群中有3台kafka机器。
kafka01
kafka02
kafka03
kafka version - 0.10.0.2.6
每台卡夫卡机器( kafka03 )都有带有18T的磁盘。
和
default.replication.factor=3
最后一台卡夫卡机器松开了磁盘(磁盘不健康，我们需要更换它)
因此，我们替换了磁盘，并再次在磁盘上创建文件系统，并再次创建主题。
但是-众所周知，在从主题中删除kafka数据之前，我们需要删除/var/kafka/kafka-logs中的所有主题。
然后更换磁盘是安全的。
但情况并非如此，因为突然磁盘缩小了，我们没有删除主题
浏览 0提问于2019-05-21得票数 0
回答已采纳
我有一个带有Kafka应用程序的Springboot，我的Kafka集群从docker文件开始。但是，如果Kafka集群保持启动，但是Spring应用程序重新启动，则无法接收任何消息(函数正常工作)。
属性文件：
server.port=18080
spring.kafka.bootstrap-servers=localhost:29092,localhost:39092
spring.kafka.listener.ack-mode=MANUAL_IMMEDIATE
spring.kafka.consumer.auto-offset-reset=latest
spring.kafka.cons
浏览 8提问于2022-05-31得票数 0
1回答
我已经创建了一个spring引导应用程序来将消息发布到Kafka队列。为此，我使用spring cloud stream和Kafka绑定器作为依赖项。问题是，如果我的应用程序因为默认配置而停机2分钟，它就会不断尝试连接到Kafka broker。我已经使用下面的属性减少了该时间，并将其设置为1000ms并获得超时异常spring.kafka.properties.request.timeout.ms:1000。但是，我的spring应用程序仍然在异常之后运行。如果Kafka broker不可连接，我希望它失败。我已经为该spring.kafka.admin.fail-fast=true尝试了
浏览 21提问于2019-05-22得票数 1
我尝试过kafka身份验证SASL_PLAINTEXT / SCRAM，但是身份验证在春季启动时失败了。
我试着改变SASL_PLAINTEXT /平原，它是有效的。但是SCRAM是身份验证失败的SHA-512和SHA-256
做了很多不同的事情，但没有用.我怎么才能修好它？
经纪人日志
broker1 | [2020-12-31 02:57:37,831] INFO [SocketServer brokerId=1] Failed authentication with /172.29.0.1 (Authentication failed during authenticatio
浏览 0提问于2020-12-31得票数 1
回答已采纳
在卡夫卡重新启动后，春季启动的消费者微型服务无法向某个主题发送消息。
使用坞群配置，我安装了带有1个kafka broker和2个spring引导微服务(生产者和消费者)的单节点集群。我使用的是弹簧引导2.0.3
消费者和生产者(spring )在同一个覆盖网络“network”上，因此他们访问kafka的服务名为"kafka:9092“。
第一次发车一切都很顺利。
然后卡夫卡才重新开始，之后消费者就无法再发送来自卡夫卡主题的信息了。
由于docker-compose.yml (例如max_attempts: 3 => max_attempts: 4)中的小改动，
浏览 0提问于2019-05-08得票数 1
大家好，各位程序员！
我正在学习Docker和Kafka，我将非常感谢您的帮助。问题是应用程序能够连接到Kafka，但不能发布任何事件。错误：
org.apache.kafka.common.errors.TimeoutException: Expiring 2 record(s) for wages-local-0:120001 ms has passed since batch creation
当一个Docker容器中的Spring应用程序试图发布到另一个容器中的Kafka时，就会出现这个问题：
version: '3'
services:
zookeeper:
浏览 4提问于2021-11-27得票数 1
回答已采纳
Spring应用程序在我的机器上本地运行并通过docker访问Kafka时运行良好，但是当我将Spring应用程序作为集群中的容器添加时，它就不能工作了。我收到错误消息：“无法建立到节点-1 (localhost/127.0.0.1:9092)的连接。代理可能不可用。”
下面列出的是spring应用程序的docker-组合、dockerfile和application.properties。
docker-compose.yml
version: "3"
services:
zookeeper:
image: 'bitnami/zookeeper:late
浏览 0提问于2021-12-04得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
