kafka创建topic

cd /data/kafka_2.13-2.8.0/bin/  下

-- 创建

./kafka-topics.sh --create \
  --bootstrap-server ip:9092 \
  --topic XXXX_topic \
  --partitions 2 \
  --replication-factor 1 \
  --config retention.ms=604800000 \
  --config segment.bytes=536870912 \
  --config compression.type=lz4 \
  --if-not-exists

 -- 创建

./kafka-topics.sh   --bootstrap-server IP:9092,IP:9092,IP:9092   --create   --topic xxx_topic   --partitions 6   --replication-factor 2

-- topic列表
./kafka-topics.sh --bootstrap-server IP:9092 --list

-- 生产者 生产
./kafka-console-producer.sh broker-list --bootstrap-server IP:9092 --topic XXXXXX
json数据

-- 消费者 数据
./kafka-console-consumer.sh --bootstrap-server IP:9092 --topic XXXXXXX --from-beginning

-- 删除
./kafka-topics.sh --delete --topic XXXXX --bootstrap-server IP:9092

-- 新增
./kafka-topics.sh --create --topic XXXXX --bootstrap-server IP:9092 --replication-factor 2 --partitions 3
-- 积压
./kafka-consumer-groups.sh --bootstrap-server IP:9092 --describe --all-groups | grep XXXXXXXX
-- 详情
./kafka-topics.sh --describe --bootstrap-server IP:9092 --topic XXXXXXXX

-------------------------

设备监听数--连接 / 等待 
netstat -anp | grep 12210 | grep ESTABLISHED | wc -l
netstat -anp | grep 12210 | grep TIME_WAIT | wc -l
echo 报文 |xxd -r -p > /dev/tcp/IP/PORT