我想测试Kafka/Flink的整合,例如使用
流程如下:
问题是如何测试这个流程?
我所说的测试是单元/集成测试。
谢谢!
FlinkKafkaConsumer011
和FlinkKafkaProducer011
。流程如下:
- 使用Flink从Kafka中读取
- 使用Flink进行操作
- 使用Flink将结果写入另一个Kafka Topic
问题是如何测试这个流程?
我所说的测试是单元/集成测试。
谢谢!
FlinkKafkaConsumer***
和FlinkKafkaProducer***
,似乎它不能与此嵌入式kafka一起工作,因为它们不是KafkaConsumer或KafkaProducer。 - Thomas