问题

创建消息:

消费消息命令提示信息如下,无法消费:

原因:

kafka版本问题,高版本不再支持此消费命令,新的消费命令如下:

./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic wordsendertest --from-beginning

执行新命令后成功消费:

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐