https://apache.googlesource.com/kafka/+/trunk/examples/src/main/java/kafka/examples/Consumer.java?autodive=0%2F