kafka 命令行查看 Consumer Group
时间: 2023-06-30 15:22:14 浏览: 102
可以使用 Kafka 自带的命令行工具 kafka-consumer-groups.sh 来查看 Consumer Group 的状态。该工具可以列出当前 Consumer Group 中所有消费者的状态,以及它们消费的 Topic 和分区信息。
以下是查看 Consumer Group 状态的命令行示例:
```
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group
```
其中,--bootstrap-server 参数指定 Kafka 的服务器地址和端口号,--describe 参数表示列出 Consumer Group 的详细信息,--group 参数指定 Consumer Group 的名称。
执行该命令后,会列出该 Consumer Group 中所有消费者的详细信息,包括消费者 ID、所消费的 Topic 和分区、当前消费的偏移量等。这些信息可以帮助我们了解 Consumer Group 的状态,以及每个消费者的消费情况。
相关问题
Kafka 命令行操作
}
void EnterWorkingMode(void)
{
// TODO: Add code to enter working mode
}
void WriteAddrData(uint16_t addr,K 命令行操作包括以下几个方面:
1. 创建主题:使用 kafka-topics.sh 脚本创建主题 uint8_t data)
{
HAL_FLASH_Program(FLASH_TYPEPROGRAM_HALFWORD, EEPROM_BASE_ADDR + addr, data);
}
uint8,例如:
```
./kafka-topics.sh --create --topic my-topic --zookeeper localhost:2181 --replication-factor 1 --partitions 1
```
2. 查看主题:使用 kafka-topics.sh 脚本查看主题信息,_t ReadAddrData(uint16_t addr)
{
return (*((uint8_t *) (EEPROM_BASE_ADDR + addr)));
}
void DetectB例如:
```
./kafka-topics.sh --describe --topic my-topic --zookeeper localhost:2181
```
3. 生ottlePosition(uint16_t addr)
{
uint8_t AddrData = AddrList[addr];
uint8_t BottleDetect = HAL_GPIO产消息:使用 kafka-console-producer.sh 脚本生产消息,例如:
```
./kafka-console-producer.sh --broker-list_ReadPin(BOTTLE_DETECT_GPIO_PORT, BOTTLE_DETECT_GPIO_PIN);
if (BottleDetect == AddrData)
{
localhost:9092 --topic my-topic
```
4. 消费消息:使用 kafka-console-consumer.sh 脚本消费消息, // Correct bottle position, blink LED 3 times
for (uint8_t i = 0; i < 3; i++)
例如:
```
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --from-beginning
```
{
HAL_GPIO_WritePin(LED_GPIO_PORT, LED_GPIO_PIN, GPIO_PIN_RESET);
HAL_Delay(100);
HAL_GPIO_Write5. 查看消费者组:使用 kafka-consumer-groups.sh 脚本查看消费者组信息,例如:
```
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
```
6. 查看消费者组消费Pin(LED_GPIO_PORT, LED_GPIO_PIN, GPIO_PIN_SET);
HAL_Delay(100);
}
}
else
{
情况:使用 kafka-consumer-groups.sh 脚本查看消费者组消费情况,例如:
```
./kafka // Incorrect bottle position, blink LED 3 times
for (uint8_t i = 0; i < 3; i++)
{
HAL_GPIO_WritePin(LED_GPIO_PORT, LED_GPIO_PIN, GPIO_PIN_RESET);
HAL_Delay(500);
HAL_GPIO_Write-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group
```
以上是 Kafka 命令行操作的基本内容,使用时需要注意参数的设置。
kafka查看集群
要查看 Kafka 集群,可以使用 Kafka 自带的命令行工具 `kafka-topics.sh`、`kafka-consumer-groups.sh`、`kafka-acls.sh` 等。以下是一些常用的命令:
1. 查看所有的 topic:
```
bin/kafka-topics.sh --list --zookeeper localhost:2181
```
2. 查看某个 topic 的详情:
```
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic my-topic
```
3. 查看所有 consumer group:
```
bin/kafka-consumer-groups.sh --list --zookeeper localhost:2181
```
4. 查看某个 consumer group 的详情:
```
bin/kafka-consumer-groups.sh --describe --zookeeper localhost:2181 --group my-group
```
注意,这里的 `my-group` 是你要查询的消费者组的名称。
5. 查看 ACL:
```
bin/kafka-acls.sh --authorizer-properties zookeeper.connect=localhost:2181 --list
```
可以使用 `--topic` 参数指定要查看的 topic 的 ACL。
以上命令中,`--zookeeper` 参数指定 ZooKeeper 连接信息,`--topic` 参数指定要操作的 topic,`--group` 参数指定要操作的消费者组。
相关推荐
![pdf](https://img-home.csdnimg.cn/images/20210720083512.png)
![zip](https://img-home.csdnimg.cn/images/20210720083736.png)
![zip](https://img-home.csdnimg.cn/images/20210720083736.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)