multipart-topic 이라는 이름의 토픽을 만들어서 연습을 해볼 것이기 때문에 'multipart-topic'이라는 이름의 topic이 있다면 삭제하고 시작하도록 해보겠습니다.
kafka-topics --bootstrap-server localhost:9092 --delete --topic multipart-topic
multipart-topic 이라는 이름의 topic을 만들도록 해보겠습니다.
kafka-topics --bootstrap-server localhost:9092 --create --topic multipart-topic --partitions 3
2000 개의 메세지를 넣어보고 로그를 확인해 보겠습니다.
2000개의 메세지를 만들고 보내보는 커맨드입니다.
2. keyload.log 파일 만들기
touch keyload.log
3. key 메시지 2000개를 keyload.log에 기록하기.
for i in {1..2000}
do
echo "$i:test key message sent test00000000000000 $i" >> keyload.log
done
4. keyload.log 파일 기반으로 메시지 2000개 전송.
kafka-console-producer --bootstrap-server localhost:9092 --topic multipart-topic \
--property key.separator=: --property parse.key=true < keyload.log
kafka log 가 저장되는 곳으로 이동해봅니다.
cd ~/data/kafka-logs/multipart-topic-0
kafka-dump-log 커맨드를 실행하고 파일을 지정해줍니다.
kafka-dump-log --deep-iteration --files /home/min/data/kafka-logs/multipart-topic-0/00000000000000000000.log --print-data-log
'공부방 > Kafka' 카테고리의 다른 글
Kafka config 구분 및 이해 (0) | 2023.05.13 |
---|---|
Consumer group 과 Rebalancing 실습 (0) | 2023.05.13 |
Kafka (0) | 2023.05.05 |
kafka (0) | 2023.05.01 |