【发布时间】:2020-11-14 11:00:56
【问题描述】:
仅出于测试目的,我想自动化需要检查 Kafka 消息内容的场景,所以只是想知道是否可以使用 Kafka Java 库直接从 TOPIC 读取没有消费者的消息?
我是 Kafka 的新手,所以任何建议都会对我有好处。
提前致谢!
【问题讨论】:
标签: testing apache-kafka kafka-consumer-api
仅出于测试目的,我想自动化需要检查 Kafka 消息内容的场景,所以只是想知道是否可以使用 Kafka Java 库直接从 TOPIC 读取没有消费者的消息?
我是 Kafka 的新手,所以任何建议都会对我有好处。
提前致谢!
【问题讨论】:
标签: testing apache-kafka kafka-consumer-api
您可以通过 SSH 连接到有问题的代理,然后将日志段转储为反序列化的方式,但只需使用任何语言(不一定是 Java)的使用者将花费更少的时间
“出于测试目的”Kafka Java API 提供了 MockProducer 和 MockConsumer,它们由 Lists 支持,而不是完整的 broker
【讨论】: