@KafkaListener(groupId = "TEST", topics = TOPIC_OUT)
public synchronized void receive(ConsumerRecord<Word, WordCount> record)
{
log.debug("Received message: {}", record);
@KafkaListener(groupId = "TEST", topics = TOPIC_OUT)
public synchronized void receive(ConsumerRecord<Word, WordCount> record)
{
log.debug("Received message: {}", record);