kafka集群+zookeeper集群常见问题与命令

偏执的太偏执、 2022-09-22 14:00 194阅读 0赞

# 常见疑问 #

1、生产者无法产生消息  
kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.  
将slf4j-nop-1.7.21.jar上传到kafka的lib包下  
参考文章：[http://stackoverflow.com/questions/23903843/apache-kafka-example-error-failed-to-send-message-after-3-tries][http_stackoverflow.com_questions_23903843_apache-kafka-example-error-failed-to-send-message-after-3-tries]

# 常用命令 #

## zk启动 ##

\[root@localhost bin\]\# ./zkServer.sh start

## kafka启动 ##

\[root@localhost bin\]\# ./kafka-server-start.sh -daemon ../config/server.properties

## 创建topic ##

\[root@localhost bin\]\# ./kafka-topics.sh –create –zookeeper 192.168.21.49:12181 –replication-factor 1 –partitions 1 –topic test

## 查看当前集群的可用topic ##

\[root@localhost 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][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的运行情况 ##

[http_stackoverflow.com_questions_23903843_apache-kafka-example-error-failed-to-send-message-after-3-tries]: http://stackoverflow.com/questions/23903843/apache-kafka-example-error-failed-to-send-message-after-3-tries
[http_www.slf4j.org_codes.html_multiple_bindings]: http://www.slf4j.org/codes.html#multiple_bindings