[...] try (final KafkaConsumer consumer = new KafkaConsumer<>(props)) { consumer.subscribe(Collections.singletonList(TOPIC)); while (true) { ConsumerRecords records = consumer.poll(10); for (ConsumerRecord record : records) { String key = record.key(); Payment value = record.value(); System.out.printf("key = %s, value = %s%n", key, value); } } } [...]