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,