常見疑問

常用命令

zk啟動

[[email protected] bin]# ./zkServer.sh start

kafka啟動

[[email protected] bin]# ./kafka-server-start.sh -daemon ../config/server.properties

建立topic

[[email protected] bin]# ./kafka-topics.sh –create –zookeeper 192.168.21.49:12181 –replication-factor 1 –partitions 1 –topic test

檢視當前叢集的可用topic

[[email protected] bin]# ./kafka-topics.sh –list –zookeeper 192.168.21.14:12181
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/root/kafka/kafka_2.10-0.10.0.0/libs/slf4j-log4j12-1.7.21.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/root/kafka/kafka_2.10-0.10.0.0/libs/slf4j-nop-1.7.21.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See

http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]
TEST-TOPIC
test
wangdan
wangdan1
wangdan2

檢視每個topic的執行情況

[[email protected] bin]# ./kafka-topics.sh –list –zookeeper 192.168.21.14:12181
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/root/kafka/kafka_2.10-0.10.0.0/libs/slf4j-log4j12-1.7.21.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/root/kafka/kafka_2.10-0.10.0.0/libs/slf4j-nop-1.7.21.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See

http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]
TEST-TOPIC
test
wangdan
wangdan1
wangdan2