回答情况：
提问时间：
问题标签：
47,131] INFO [Controller id=2, targetBrokerId=1] Client requested connection close from node 1 (org.apache.kafka.clients.NetworkClient(org.apache.kafka.clients.NetworkClient)
kafka-2 | [2022-10-24 15:41:47,232] WARN(org.apache.kafka.clients.Ne
浏览 11修改于2022-10-24得票数 1
回答已采纳
我使用以下mm2.属性：clusters=source, dest
{ "connector.class":"org.apache.kafka.connect.mirror.MirrorSourceConnector}并在目标集群
浏览 5修改于2020-01-23得票数 2
output { id => "plugin_SharedAlarmCreated"
bootstrap_servers => "kafka-1:9092,kafka在输出{r\n id => "plugin_SharedAlarmCreated"\r\n bootstrap_servers => " kafka -1:9092，kafka-2:9092，kafka-2:9092，kafka-2:9092
浏览 8提问于2022-10-15得票数 0
回答已采纳
-2:9092,kafka-3:9092" kafka-2: container_name: kafka-2 - "29092:9092"
浏览 5修改于2020-11-01得票数 4
1回答
我正在将Spring.kafka.boot-server属性设置为："kafka-1:9092;kafka-2:9093，kafka-3:9094“以及我的主机文件中的所有名称。kafka-1服务器(只是其他服务器)，它发生了一个例外：
org.springframework.kafka.core.KafkaProducerException:未能发送；嵌套的异常是org.apache.kafka.common.errors.TimeoutException当我再次启动kafka-1时，该服务将获取我的消费者ConcurrentKafkaList
浏览 2修改于2018-09-03得票数 6
Caused by: org.apache.kafka.clients.consumer.CommitFailedException: ?at org.apache.kafka.streams.processor.internals.StreamTask.access$000(StreamTask.java:49)at org.apache.kafka.streams.processor.int
浏览 3修改于2018-09-30得票数 6
回答已采纳
KAFKA_ADVERTISED_LISTENERS value: LISTENER_0 我运行了3个kafka pod，kafka-0正在连接，但kafka-1和kafka1/1 Running
浏览 25修改于2020-09-30得票数 0
回答已采纳
BROKER_ID_COMMAND结果：kafka-1 = 1KAFKA_ADVERTISED_HOST_NAME=kafka-0KAFKA_ADVERTISED_HOST_NAME=kafka
浏览 9提问于2017-11-27得票数 6
回答已采纳
2回答
kafka节点不断停止打印以下错误： at org.apache.zookeeper.server.quorum.QuorumCnxManager.connectAll(QuorumCnxManager.java:558)
at org.apache.zookeeper.server.quor
浏览 2修改于2019-03-03得票数 1
回答已采纳
2回答
:42181 network_mode: "host"
docker-compose run -d --service-ports kafkanot attempt to authenticate using SASL (unknown e
浏览 0修改于2018-11-07得票数 2
hdfs.url": "hdfs://namenode:9000","confluent.topic.bootstrap.servers": "kafka-1:19092,kafka-2:29092,kafka-3:39092",&quo
浏览 15提问于2022-11-28得票数 0
回答已采纳
kafkaListenerEndpointRegistry.getListenerContainer(listenerId).start();} kafkaKAFKA_ZOOKEEPER_CONNECT: zookeeper-1:2181,zookeeper-2:2181,zookeeper-3:2181
KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka
浏览 8修改于2022-05-31得票数 0
- coordinator - environment - kafka-1:127.0.0.1 env_file: extra_hosts: - kafka- historical - environment - kafk
浏览 7修改于2020-12-15得票数 1
回答已采纳
CrashLoopBackOff -0 2/3 CrashLoopBackOff 3 2 m40 my-confluent-oss CrashLoopBackOff 3 2 m13s my-confluent-oss kafka
浏览 0修改于2019-05-23得票数 0
回答已采纳
KAFKA_INTER_BROKER_LISTENER_NAME: INTERNAL kafka(org.apache.zookeeper.ClientCnxn)heard from server in 30006ms for se
浏览 42修改于2022-04-13得票数 1
回答已采纳
zookeeper-2:22181,zookeeper-3:32181 image: confluentinc/cp-kafka:latest ports:
浏览 12提问于2022-09-20得票数 1
/kafka1/data:/var/lib/kafka/data image: confluentinc/cp-kafka:latest KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka
浏览 22修改于2022-07-20得票数 2
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号