主题脚本命令及其参数
| 参数 |
描述 |
| --bootstrap-server |
连接的Kafka Broker主机名称和端口号 |
| --topic |
操作的topic名称 |
| --create |
创建主题 |
| --delete |
删除主题 |
| --alter |
修改主题 |
| --list |
查看所有主题 |
| --describe |
查看主题详细描述 |
| --partitions |
设置分区数 |
| --replication-factor |
设置分区副本 |
这些参数可以与kafka-topics.sh（Unix/Linux）或kafka-topics.bat（Windows）命令一起使用，用于管理Kafka主题。根据需要，选择使用适当的参数来执行相应的操作。
消费者脚本命令参数：
| 参数 |
描述 |
| --bootstrap-server |
连接的Kafka Broker主机名称和端口号 |
| --topic |
消费的topic名称 |
| --group-id |
消费者所属的消费者组ID |
| --from-beginning |
从最早的偏移量开始消费 |
| --partition |
指定要消费的分区 |
| --offsets |
指定要消费的分区的偏移量 |
| --max-messages |
指定要消费的最大消息数量 |
| --timeout-ms |
指定超时时间（毫秒），在等待新消息时使用 |
| --property <String=String> |
设置其他的消费者属性 |
生成者脚本命令参数：
| 参数 |
描述 |
| --bootstrap-server |
连接的Kafka Broker主机名称和端口号 |
| --topic |
发送消息的topic名称 |
| --key |
发送消息的键（可选） |
| --value |
发送消息的值 |
| --property <String=String> |
设置其他的生产者属性 |
这些参数可以与Kafka提供的相应脚本命令一起使用，用于执行消费者和生产者的操作。根据需要，您可以选择使用适当的参数来配置消费者和生成者的行为。