开发者

Filtering Kafka Records Python

I have a Kafka topic which consumes from different sources, I want to filter records based on some rules and deliver records to two different topics (one for valid records and one for invalid ones开发者_JS百科). Is there any idea how the code logic should be? Thanks,

0

上一篇:

下一篇:

精彩评论

暂无评论...
验证码 换一张
取 消

最新问答

问答排行榜