text 卡夫卡主题一代

Posted 2021-05-01

# starting server

bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties

To start in background
nohup bin/zookeeper-server-start.sh config/zookeeper.properties &
nohup bin/kafka-server-start.sh config/server.properties &

# deleting topics

bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic test
bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic response_topic
bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic 

# creating a topic

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic post_book
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic response_topic

# listing topics

bin/kafka-topics.sh --list --zookeeper localhost:2181

# Insufficient memory for the Java Runtime Environment to continue

export KAFKA_HEAP_OPTS="-Xmx256M -Xms128M"

# Kill process on a port

sudo kill `sudo lsof -t -i:9001`