为什么Kafka 0.10 kafka-console-consumer.sh缺少--group参数？
Kafka 0.10版本的kafka-console-consumer.sh工具缺少--group参数的原因是该版本的Kafka还未引入基于消费者组的消费者API。在Kafka 0.10之前的版本中，消费者是以单个消费者的形式进行消费的，没有引入消费者组的概念。
消费者组是Kafka中的一个重要概念，它允许多个消费者协同工作以实现负载均衡和容错性。通过将消费者组中的消费者分配到不同的分区上，可以实现消息的并行处理和高吞吐量。
然而，在Kafka 0.10版本中，还未引入消费者组的概念，因此kafka-console-consumer.sh工具没有--group参数。如果需要使用消费者组功能，建议升级到Kafka的较新版本，如Kafka 0.11及以上版本。
腾讯云提供的与Kafka相关的产品是消息队列 CKafka，它是腾讯云基于Kafka技术打造的分布式消息队列服务。CKafka提供高可靠、高吞吐量、低延迟的消息发布和订阅服务，适用于大数据、实时计算、日志采集、消息通信等场景。
了解更多关于腾讯云CKafka的信息，请访问：CKafka产品介绍
相关·内容
2回答
该命令不知道"-- group“是什么意思，帮助中也没有显示任何参数，这些参数似乎是针对您要从中消费的组的。
# where is the "--group mygroup" arg below?kafka-console-consumer.sh --zookeeper localhost:2181 --topic mytopic
浏览 20提问于2017-06-28得票数 1
回答已采纳
2回答
最新Kafka版本的消费群体列表存放在哪里？
apache-kafka、apache-zookeeper、kafka-consumer-api
显然，在早期的kafka版本中，某个消费群体的消费者列表存储在zookeeper中。对于最新的kafka版本，这些信息存储在哪里？
浏览 18提问于2019-12-21得票数 2
回答已采纳
1回答
Kafka 0.10.1.0变化抵消时间
apache-kafka、offset、consumer
Elasticsearch管道在两个logstash实例之间使用Kafka集群设置。我需要重置一个主题的12小时后补偿，并重新启动消费者。bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list kfkserver:9092 --topic topicname --time
浏览 3提问于2017-02-28得票数 1
4回答
“组”选项是否被卡夫卡-控制台-消费者工具所反对？如果是这样的话，我如何设置消费者组使用卡夫卡-控制台-消费者。
apache-kafka、kafka-consumer-api
我试图使用命令行工具-kafka-console- run . to为同一主题以不同的组名运行多个使用者。当我设置-组选项时，它会失败，错误是“组不是公认的选项”。在我升级到最新的kafka版本(kafka_2.11-0.8.2.2)之前，它一直运行良好。
浏览 3提问于2015-12-09得票数 5
回答已采纳
1回答
卡夫卡制片人似乎没有正常工作。
java、apache-kafka、kafka-producer-api
import java.util.Properties;import org.apache.kafka.clients.producer.KafkaProducer; props.
浏览 0提问于2017-04-17得票数 1
回答已采纳
2回答
kafka消费者应用程序接口consumer.poll()不工作，没有错误，没有异常，只是阻塞
java、apache-kafka、kafka-consumer-api
&bin/kafka-console-consumer.sh --zookeeperbin/kafka-console-consumer.sh<
浏览 9提问于2017-07-09得票数 4
1回答
Kafka消费者无法读取Windows上的数据
java、apache-kafka
我正在尝试编写一个简单的Kafka消费者来读取windows机器上的数据。但是我的消费者不能读取任何数据。生产者产生了20多条消息，但没有一条消息被消费。ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,StringDeserializer.class.getName());
浏览 0提问于2020-05-13得票数 1
1回答
解释bin/kafka-run-class.sh .run kafka.tools.ConsumerOffsetChecker --动物园管理员本地主机:2181-组group1
apache-kafka、kafka-consumer-api
bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper localhost:2181 --group group1Group Topic Pid Offset logSize Laggroup1_nilotpal-1469374217666-b7619d68-0
group</
浏览 2提问于2016-07-25得票数 0
回答已采纳
1回答
使用-max-消息时，Kafka控制台使用者提交了错误的偏移量。
apache-kafka、kafka-consumer-api
_2.11-1.1.0/bin/kafka-console-consumer.sh --bootstrap-server 192.168.1.23:9092 --topic test.offset --/kafka_2.11-1.1.0/bin/kafka-consumer-groups.sh --bootstrap-server 192.168.1.23:9092 --describe --groupConsumer group 'my-con
浏览 1提问于2020-02-28得票数 2
回答已采纳
5回答
卡夫卡如何从__consumer_offsets主题中阅读
apache-kafka、kafka-consumer-api
(我还通过检查Zk：/consumers/consumer_group_name/offsets/topic_name/partition_number中的路径，验证了动物园管理员中没有存储任何偏移量。：bin/kafka-console-consumer.sh --consumer.config kafka_offset_consumer.config --topic __consumer_offsets/bin/kafka-sim
浏览 10提问于2015-11-25得票数 37
回答已采纳
1回答
卡夫卡蒙戈召集人没有按预期工作。
mongodb、apache-kafka、apache-kafka-connect
我对mongo使用Kafka连接(源代码)，连接工作人员正在运行，但它不是将数据写入Kafka主题，而是使用源连接器和连接器的以下配置文件：tasks.max=1database=haifakey.converter = org.apache.kafka.connect.storage.StringConverterstream
浏览 10提问于2020-01-22得票数 0
16回答
消费者不接收消息，kafka控制台，新消费者api，Kafka 0.9
apache-kafka、kafka-consumer-api
我正在为Kafka 0.9.0.0做。，因为我跑了我在localhost:9092有一个经纪人在听，因为我跑了我有一个制作人发到主题为“测试”，因为我运行
bin/kafka-console-producer.sh --broker-list localhostlet
浏览 26提问于2016-01-17得票数 43
2回答
无法在卡夫卡中看到与__consumer_offsets主题相关的偏移量
apache-spark、apache-kafka
我有一个Streaming应用程序，它从Kafka主题中读取数据并将其放在HDFS上。我希望应用程序存储抵消读到__consumer_offsets主题的消息，以便在应用程序失败时开始阅读。Map( "enable.auto.commit" -> "true",
"group.id$ /usr/hdp/
浏览 0提问于2018-11-08得票数 0
1回答
Kafka流字计数应用
scala、apache-kafka、streaming、apache-kafka-streams
我正在使用kafka (Kakfa版本: 0.10.2.0)，试图使一个简单的单词计数示例工作：。我同时运行生产者和控制台使用者：启动应用程序String, String] = textLines.mapValues(_.toUpperCase()) uppercasedWithMapValues.to("output-topic"
浏览 4提问于2017-08-02得票数 0
回答已采纳
2回答
如何在python中消费kafka的多个brokers的数据？
python、apache-kafka
/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topicreplicabin/kafka-console-consumer.sh --zookeeper localhost:2181 --from-beginninglocalhost:9093', 'localhost:9094'],
auto_off
浏览 0提问于2019-05-20得票数 0
1回答
卡夫卡__consumer_offsets和不干净的关闭？
apache-kafka
/kafka-run-class.sh kafka.admin.ConsumerGroupCommand --bootstrap-server localhost:9092 --group pigeon/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic __consumer_offsets --from-beginning/kafka-run-class.sh kafka
浏览 1提问于2017-10-12得票数 0
回答已采纳
0回答
Kafka 0.10兼容Spark 1.6.2吗？
scala、apache-spark、apache-kafka
></dependency>Kafka 0.10 support is only comingwith Spark 2.0 on Scala and Java workloads
例如，对于消费消息，Scala不处理Kafka队列参数(代理列表、zookeeper ip等)，而只是将它们直接发送到Kafka，Kafka对其
浏览 5提问于2017-01-02得票数 1
回答已采纳
1回答
Kafka授权仅在9092端口失败
apache-kafka、acl
my.host1:2181,host2:2181,host3:2181 --add --allow-principal User:second_user --consumer --topic '*' --group为什么它只适用于安全端口？我错过任何配置了吗？/bin/kafka-console-consumer.sh --bootstrap-server host1:9093,host2:9093,host3:9093 --topic test_topicrequired \
usernam
浏览 6提问于2021-08-03得票数 0
回答已采纳
1回答
Kafka 0.11 / Golang Sarama版本支持
go、apache-kafka、sarama
我花了一些时间发现我的Go应用程序连接到Kafka 0.11集群使用的是旧的0.8.2版本的库，它在响应中缺少时间戳值。我仍然在想，为什么这个版本不是从我连接的Kafka代理中获取的？我知道Python是这样做的：
from kafka impo
浏览 5提问于2017-09-25得票数 0
2回答
在kafka中处理数据流
apache-kafka
我正在尝试设置一个kafka消费者来处理来自Kafka流的数据。我能够设置到流的连接，数据是可见的，但它是特殊字符和ASCII的混合。我正在使用内置的kafka控制台，但也尝试了python版本的confluent-kafka。唯一需要遵循的参数是将SASL_PLAINTEXT安全协议与SCRAM-SHA-256一起使用。Kafka控制台 bin/kafka-console-consumer.sh --bootstrap-server server:9092
浏览 37提问于2019-04-08得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
