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