#!/bin/bash
for TOPIC in `cat list`
do
/usr/local/kafka/bin/kafka-topics.sh --zookeeper msp-zk01:2181,msp-zk02:2181,msp-zk03:2181/msp-log --partitions 3 --replication-factor 2 --topic ${TOPIC} --create
/usr/local/kafka/bin/kafka-topics.sh --zookeeper msp-zk01:2181,msp-zk02:2181,msp-zk03:2181/msp-log --alter --topic "$TOPIC" --config retention.ms=43200000
done
list파일에는 토픽명을 넣어줌'open source 설정 및 끄적 > kafka' 카테고리의 다른 글
| 카프카 확장(replica 증설) (0) | 2021.10.23 |
|---|---|
| kafka message 받기 (0) | 2021.10.23 |
| kafka topic 삭제 (0) | 2021.10.23 |
| filebeat를 통해 kafka로 전송하기 (0) | 2021.03.16 |
| omkafka (0) | 2021.03.01 |