bin/kafka-console-consumer.sh --bootstrap-server 39.134.117.143:9092,39.134.117.144:9092,39.134.117.148:9092,39.134.117.149:9092,39.134.117.150:9092 --topic PUSH_L1 --consumer_js.properties config/ssl.properties 报错

您的命令有一个错误，正确的命令应该是：

bin/kafka-console-consumer.sh --bootstrap-server 39.134.117.143:9092,39.134.117.144:9092,39.134.117.148:9092,39.134.117.149:9092,39.134.117.150:9092 --topic PUSH_L1 --consumer.config config/ssl.properties

注意，`--consumer.config` 参数后面应该是配置文件的路径，而不是 `--consumer_js.properties`。因此，您需要将 `--consumer_js.properties` 修改为 `--consumer.config`。

另外，如果您的 SSL 配置文件是 `config/ssl.properties`，则需要将 `--consumer.config` 参数后面的路径修改为 `config/ssl.properties`。

相关问题

执行./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic wordsender命令无反应

执行 `./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic wordsender` 命令无反应可能有以下几个原因：

1. **Kafka 服务未启动**：
- 确保 Kafka 服务已经启动。你可以使用 `jps` 命令查看 Kafka 相关的进程是否在运行。如果没有启动，请先启动 Kafka 服务。

2. **主题不存在**：
- 确保你要消费的主题 `wordsender` 已经创建。你可以使用以下命令查看所有主题：

     ./bin/kafka-topics.sh --list --bootstrap-server localhost:9092

如果主题不存在，可以使用以下命令创建主题：

     ./bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic wordsender

3. **没有生产者发送消息**：
- 确保有生产者正在向 `wordsender` 主题发送消息。你可以打开一个新的终端窗口，启动一个生产者并发送一些测试消息：

     ./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic wordsender

然后在生产者终端输入一些消息，看看消费者终端是否有反应。

4. **消费者组问题**：
- 如果你使用了消费者组（默认情况下会使用一个默认的消费者组），确保没有其他消费者在同一个组中消费相同的消息。你可以尝试指定一个新的消费者组：

     ./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic wordsender --group my-group

5. **网络问题**：
- 确保你的网络配置正确，Kafka 集群的地址和端口号是正确的，并且防火墙没有阻止相关的端口。

通过以上步骤，你应该能够找到并解决执行 `./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic wordsender` 命令无反应的问题。

bin/kafka-console-consumer.sh --bootstrap-server bigdata02:9092 --topic test_ogg

这是一个 Kafka 命令行消费者的启动命令，它会从名为 "test_ogg" 的 Kafka 主题中消费消息，并连接到 "bigdata02:9092" 作为 Kafka 集群的启动服务器。这个命令会在 Kafka 安装目录的 "bin" 目录下找到 "kafka-console-consumer.sh" 脚本并运行它。