Как я размещаю и принимаю сообщение Kafka в том же сборщике IntegrationFlows

Question

Я хочу сделать простого производителя / потребителя кафки с использованием весенней интеграции, как я это сделал, разделив два компоновщика, каждый из которых похож на bean, но я бы хотел сделать это только одним @ Bean

    @Bean
    fun myProducerFlow(kafkaTemplate: KafkaTemplate<*, *>): IntegrationFlow {

       return IntegrationFlows.from("testChannel")
                .handle(Kafka.outboundChannelAdapter(kafkaTemplate)
                        .topic("channel1"))
                .get()
    }

    @Bean
    fun myConsumerFlow(consumerFactory: ConsumerFactory<*, *>): IntegrationFlow {

        return IntegrationFlows.from(Kafka.messageDrivenChannelAdapter(consumerFactory,"channel1"))
                .handle { message -> println(message) }
                .get()
    }

Iжелаю что-то вроде этого:

    @Bean
    fun myFlow(kafkaTemplate: KafkaTemplate<*, *>): IntegrationFlow {

       return IntegrationFlows.from("testChannel")
                .handle(Kafka.outboundChannelAdapter(kafkaTemplate)
                        .topic("channel1"))
         .channel(Kafka.messageDrivenChannelAdapter(consumerFactory,"channel1"))
                .handle { message -> println(message) }
                .get()
    }