黑马程序员技术交流社区

标题: 【上海校区】Kafka操作命令 [打印本页]

作者: 梦缠绕的时候 时间: 2018-11-8 11:36
标题: 【上海校区】Kafka操作命令
启动zookeeper服务：
bin\windows\zookeeper-server-start.bat  config\zookeeper.properties

启动kfaka服务：
bin\windows\kafka-server-start.bat  config\server.properties

停止kafka
bin\windows\kafka-server-stop.bat

停止zookeeper
bin\windows\zookeeper-server-stop.bat

创建topic:
bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testDemo

修改topic分区（分区数只能增加不能减少）
bin\windows\kafka-topics.bat --zookeeper localhost:2181 --alter --topic HelloWorld --partitions 2

描述topic（分区数量，主题覆盖的配置，每个分区副本清单）
bin\windows\kafka-topics.bat --describe --zookeeper localhost:2181 --topic  my-replicated-topic

删除主题

bin\windows\kafka-topics.bat --zookeeper localhost:2181 --delete --topic HelloWorld

列出集群里所有topic：
bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

启动produce:
kafka-console-producer.bat --broker-list localhost:9092 --topic testDemo

启动consumer：
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic testDemo --from-beginning

覆盖主题默认参数

命令格式：

bin\windows\kafka-configs.bat -zookeeper localhost:2181 -entity-type topics -entity-name testDemo2 -alter -add-config log.retention.hours=120

可用主题配置参数

key value 描述
cleanup.policy compact 只有包含了指定的key的消息会被保留下来（压缩日志），其他的被丢掉
compression.type
“gzip”、“snappy”、“lz4”

broker将消息批次写入磁盘时所使用的压缩类型。
delete.retention.ms 整数（毫秒数）被标识为待删除的数据能保留多久，以ms为单位，该参数只对压缩日志类型的主题有效
file.delete.delay.ms 整数（毫秒数）从磁盘上删除日志片段和索引之前可以等待多长时间，以ms为单位
flush.messages 整数需要收到多少消息，才能将他们刷新到磁盘
flush.ms 整数（毫秒数）将消息刷新到磁盘之前可以等待多长时间
index.interval.bytes      日志片段的两个索引之间能够容纳的消息字节数
max.message.bytes      最大消息字节数
message.format.version      broker将消息写入磁盘时所用的消息格式，必须是有效的API版本，例如“0.10.0”
message.timestamp.difference.max.ms      消息自带的时间戳和broker收到消息时时间戳之间最大差值，ms单位
message.timestamp.type CreateTime、LogAppendTime 将消息写磁盘时采用哪种时间戳，目前支持两种格式，CreateTime客户端指定时间戳，LogAppendTime消息被写入分区时间戳。
min.cleanable.dirty.ratio      可用分区的最少同步副本
preallocate      如果被设置为true，需要为新的日志片段预分配空间
retention.bytes      主题能够保留的消息量，以字节为单位
retention.ms      主题能够保留消息多长时间，ms单位
segment.bytes      日志片段的消息字节数
segment.index.bytes      单个日志片段的最大索引字节数
segment.jitter.bytes      滚动日志片段时，在segment.ms基础上增加随机毫秒数
unclean.leader.election.enable      如果被设置为true，不彻底的首领选择无效



---------------------
作者：Mark_XC
来源：CSDN
原文：https://blog.csdn.net/Mark_Chao/article/details/83714686
版权声明：本文为博主原创文章，转载请附上博文链接！

作者: 魔都黑马少年梦 时间: 2018-11-8 17:24

作者: 不二晨 时间: 2018-11-14 15:49

~(｡≧3≦)ﾉ⌒☆

欢迎光临黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2