+ MessageProducer messageProducer(
+ KafkaMessageListenerContainer<String, String> messageListenerContainer)
+ {
+ KafkaMessageDrivenChannelAdapter<String, String> adapter =
+ new KafkaMessageDrivenChannelAdapter(messageListenerContainer);
+ adapter.setOutputChannelName("kafka-in");
+ return adapter;
+ }
+
+ @Bean
+ @Transformer(inputChannel = "kafka-in", outputChannel = "recordings")
+ public HeaderEnricher kafkaInHeaderEnricher()