https://dingxiong.github.io/posts/how-to-write-a-kafka-consumer/