Spring 4 - Kafka integration

Hej,
mam pytanko o integracje z Kafka.
W necie sa same przyklady zwiazane ze spring bootem, ale byłbym zainteresowany konfiguracja ze springiem 4.
Problem mam z konsumerem.
Nie wiem do konca jak sciagac wiadomosci.

Mam taki kod:

kafkaConsumer.subscribe(Collections.singletonList(topic));

i faktycznie konsumer zaczyna subscribowac ale nie wiem jak zrobic przechwycic ta wiadomosc.

Widzialem w examplach ze spring boota cos takiego:

    @KafkaListener(topics = "${topic}", groupId = "KafkaGroupId")
    public void consume(@Payload String message) {
        LOGGER.debug("Kafka message received: {}", message);
    }

ale niestety nie tedy droga.

Z drugiej strony co mi dziala to taki kodzik ktory znalazlem

        kafkaConsumer.subscribe(Collections.singletonList(topic));

        while (true) {
            ConsumerRecords<String, String> records = kafkaConsumer.poll(Long.MAX_VALUE);
            for (ConsumerRecord<String, String> record : records) {
                Map<String, Object> data = new HashMap<String, Object>();
                data.put("partition", record.partition());
                data.put("offset", record.offset());
                data.put("value", record.value());

                LOGGER.debug("Kafka received message: {}", data);
            }
        }

ale zastanawiam sie czy nie da sie tego zrobic ladniej niz while(true)

dzieki

masz odpalonego zookepera?

KafkaListener - czemu nie tędy droga?