cmp › slack-alt-tab-error › wsdl › 코드결합도낮추기 › MSWindowsCommands › Kafka
- CopyOffsetsOfAConsumerGroupToAnotherConsumerGroup . . . . 4 matches
#keywords Kafka, offset, consumer group
'''Copying offsets of consumer group {{{grp1}}} to {{{grp2}}} (Kafka 1.1)'''
cf. Kafka 0.10: [copying offsets of a consumer group to another consumer group in Kafka 0.10 with python script]
~/programs/kafka_2.11-1.1.0$ bin/kafka-consumer-groups.sh --describe --group grp1 --bootstrap-server localhost:9092
~/programs/kafka_2.11-1.1.0$ bin/kafka-consumer-groups.sh --describe --group grp2 --bootstrap-server localhost:9092
~/programs/kafka_2.11-1.1.0$ bin/kafka-consumer-groups.sh --reset-offsets --to-current --export --group grp1 --topic test1 --bootstrap-server localhost:9092 > /tmp/grp1-offsets.csv
~/programs/kafka_2.11-1.1.0$ cat /tmp/grp1-offsets.csv
~/programs/kafka_2.11-1.1.0$ bin/kafka-consumer-groups.sh --reset-offsets --from-file /tmp/grp1-offsets.csv --dry-run --group grp2 --topic test1 --bootstrap-server localhost:9092
~/programs/kafka_2.11-1.1.0$ bin/kafka-consumer-groups.sh --reset-offsets --from-file /tmp/grp1-offsets.csv --execute --group grp2 --topic test1 --bootstrap-server localhost:9092
~/programs/kafka_2.11-1.1.0$ bin/kafka-consumer-groups.sh --describe --group grp2 --bootstrap-server localhost:9092 - CopyingOffsetsOfAConsumerGroupToAnotherConsumerGroupInKafka0.10WithPythonScript . . . . 3 matches
#keywords Kafka, offset, consumer group
Copying offsets of consumer group grp1 to grp2 (Kafka 0.10)
cf. Kafka 1.1: [copy offsets of a consumer group to another consumer group]
The following python scripts are available from [https://github.com/gimslab/scripts/tree/master/copy-kafka-offsets-0.10.1.1-python3 github]
~/programs/kafka_2.11-0.10.1.1$ bin/kafka-consumer-groups.sh --describe --group grp1 --bootstrap-server localhost:9092
~/programs/kafka_2.11-0.10.1.1$ bin/kafka-consumer-groups.sh --describe --group grp2 --bootstrap-server localhost:9092
~/programs/kafka-p1$ bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group grp1
~/programs/kafka-p1$ bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group grp2
~/programs/kafka-p1$ bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group grp2
~/programs/kafka-p1$ bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group grp1
~/programs/kafka-p1$ bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group grp2
~/programs/kafka-p1$ - Kafka . . . . 3 matches
["Kafka Partition Assignment Strategy"]
KafkaCat: Kafka Netcat - Kafka Partition Assignment Strategy . . . . 2 matches
[Kafka] >
cf. https://velog.io/@hyun6ik/Apache-Kafka-Partition-Assignment-Strategy - 개발툴 . . . . 2 matches
= Kafka =
* Kafka Cat - MessagePartitioningSolutions . . . . 1 match
#keywords Kafka - SystemRebuilding-201912 . . . . 1 match
Kafka Consuming을 이벤트 처리의 시작점으로 하는 팀의 입장에서 고충과 노하우?도 따로 정리해보자. 아.. rebalancing..
