I want to point out for those that don't know - MongoDB now has a great query interface for Kafka using the Aggregation Language: https://www.mongodb.com/products/platform/atlas-stream-processing
Full disclosure: I work at MongoDB. ;-) and co-founded a company (Eventador.io) that built the Flink SQL engine, which Cloudera now sells.