标签：member 不能 war replica 信息 scribe eset too null
kafka-topics.sh --zookeeper 47.52.199.52:2181 --create --topic test-15 --replication-factor 1 --partitions 3
kafka-topics.sh --zookeeper zk.server --alter --topic test --replication-factor 1 --partitions 3
注：topic一旦创建，partition只能增加，不能减少
kafka-topics.sh --zookeeper zk.server --delete --topic test
kafka-topics.sh --zookeeper zk.server --list
kafka-topics.sh --zookeeper zk.server --topic test --describe
./bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 47.52.199.51:9092 --topic consumer-send
./bin/kafka-consumer-groups.sh --list --bootstrap-server 192.168.88.108:9092
./bin/kafka-consumer-groups.sh --bootstrap-server 47.52.199.51:9092 --group test-1 --describe
结果：
TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
consumer-send 0 5697 5697 0 consumer-3-77500c76-ef09-4047-9ae0-89c20cc379fc /183.17.238.48 consumer-3
producer-syn 0 4125 4125 0 - - -
CURRENT-OFFSET:当前消费偏移量
LOG-END-OFFSET：末尾偏移量
./bin/kafka-consumer-groups.sh --bootstrap-server 47.52.199.51:9092 --group test-1 --delete
[root@izj6c46svwddzpu0evy0vbz kafka_2.11-2.0.1]# ./bin/kafka-consumer-groups.sh --bootstrap-server 47.52.199.51:9092 --group test_4 --describe OpenJDK 64-Bit Server VM warning: If the number of processors is expected to increase from one, then you should configure the number of parallel GC threads appropriately using -XX:ParallelGCThreads=N Consumer group ‘test_4‘ has no active members. TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID consumer-send 0 5697 5697 0 - - - producer-syn 0 4125 4125 0 - - -
./bin/kafka-consumer-groups.sh --bootstrap-server 47.52.199.51:9092 --group test_4 --reset-offsets -to-offset 100 --topic consumer-send --execute
./bin/kafka-consumer-groups.sh --bootstrap-server 47.52.199.51:9092 --group test_4 --reset-offsets -to-offset 100 --topic consumer-send --export > 1.txt
./bin/kafka-preferred-replica-election.sh --zookeeper 47.52.199.51:2181/chroot
1）启动kafka
nohup bin/kafka-server-start.sh config/server.properties > /dev/null 2>&1 &
（2）创建消费者
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic middleware --from-beginning
（3）创建生产者
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
标签：member 不能 war replica 信息 scribe eset too null
原文地址：https://www.cnblogs.com/wangzhuxing/p/10127497.html
