WARN [Consumer clientId=consumer-console-consumer-22243-1, groupId=console-consumer-22243] Bootstrap

配置文件有误，修改配置文件

# Name the components on this agent
a1.sources = r1
a1.sinks = k1
a1.channels = c1#define a memory channel called c1 on a1
a1.channels.c1.type = memory
a1.channels.c1.capacity = 1000
a1.channels.c1.transactionCapacity = 100
#Describe/configure the source
a1.sources.r1.channels = c1
a1.sources.r1.type = exec
a1.sources.r1.command = tail -f /opt/flume-1.9.0/log#Describe the sink
a1.channels.channel1.type = org.apache.flume.channel.kafka.KafkaChannel
a1.channels.channel1.kafka.bootstrap.servers = hadoop102:9092,hadoop103:9092,hadoop104:9092
a1.channels.channel1.kafka.topic = test
a1.channels.channel1.kafka.consumer.group.id = flume-consumer

修改flume启动命令：

flume-ng agent -n a1 -c conf -f conf/flume_kafka1.conf -Dflume.root.logger=INFO,console

修改kafka消费者启动命令：

kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --from-beginning --topic test

WARN [Consumer clientId=consumer-console-consumer-22243-1, groupId=console-consumer-22243] Bootstrap相关推荐

WARN [Consumer clientId=consumer-1, groupId=console-consumer-55928] 1 partitions have leader brokers
一问题描述同事反馈我们的三节点kafka集群当其中一台服务器宕机后,业务受到影响,无法生产与消费消息.程序报错: WARN [Consumer clientId=consumer-1, group ...
WARN NetworkClient: [Consumer clientId=consumer-g1-1, groupId=g1] Error connecting to node
在Spark Streaming连接Kafka的时候出现了WARN NetworkClient: [Consumer clientId=consumer-g1-1, groupId=g1] Error ...
Kafka整体结构图、Consumer与topic关系、Kafka消息分发、Consumer的负载均衡、Kafka文件存储机制、Kafka partition segment等（来自学习资料）
##1． Kafka整体结构图 Kafka名词解释和工作方式  Producer : 消息生产者,就是向kafka broker发消息的客户端.  Consumer : 消息消费者,向kafka ...
部署kafka集群后创建主题报错WARN [AdminClient clientId=adminclient-1] Error connecting to node 14ca304
[2022-05-19 06:58:54,549] WARN [AdminClient clientId=adminclient-1] Error connecting to node 14ca304 ...
WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not
kafka中如果输入命令报错WARN [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9 ...
【Error】 WARN [Producer clientId=console-producer] Error while fetching metadata wit
今天在使用Kafka生产数据时出现一个错误,具体报错如下 2021-12-29 18:17:50,662] WARN [Producer clientId=console-producer] Erro ...
WARN [Producer clientId=console-producer] Connection to node -1 could not be established.
WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may ...
console的高级用法，console.log带颜色的字
先展示效果图: <!-- /*** @Author: Ding Jianlong* @Date: 2018-11-08 14:37:05* @Last Modified by: Ding Jia ...
RocketMQ-初体验RocketMQ(04)_使用RocketMQ Console源码搭建RocketMQ Console与基本使用
文章目录 Github地址 IDEA中部署修改两处地方修改application.properties配置修改依赖启动RokcetMQ Console 访问RocketMQ Console ...
C＃程序演示Console.Write（）和Console.WriteLine（）的示例
Console.Write() and Console.WriteLine() methods are used to print the text (values) on the Console. ...

WARN [Consumer clientId=consumer-console-consumer-22243-1, groupId=console-consumer-22243] Bootstrap

WARN [Consumer clientId=consumer-console-consumer-22243-1, groupId=console-consumer-22243] Bootstrap相关推荐

最新文章

热门文章