如何初始化kafka ConsumerRecords 在kafka中进行测试

问题描述 投票:5回答:1

[我正在编写卡夫卡消费者组件的测试用例,并模拟返回kafkaConsumer.poll()实例的ConsumerRecords<String,String>。我想初始化ConsumerRecords并在模拟中使用它,但是ConsumerRecords的构造函数期望实际的kafka主题,而我在测试中没有。我认为的一种方法是保留对象的序列化副本并反序列化以初始化ConsumerRecords。还有其他方法可以达到相同目的。

java mocking apache-kafka powermock kafka-consumer-api
1个回答
7
投票

这里是一些示例代码(Kafka客户端库版本0.10.1.1):

© www.soinside.com 2019 - 2024. All rights reserved.