@EnableKafka
props.put( ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, myKafkaProperties.getBootstrapAddress()); props.put( ConsumerConfig.GROUP_ID_CONFIG, MyKafkaProperties.GROUP_ID); props.put( ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class); props.put( ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
factory.setConsumerFactory(consumerFactory());
@KafkaListener(topics="blabla", groupId="myconsumerGroup")# springboot-kafka-consumer