我查看了文档，它只说明了自动提交如何与 poll() 这里，以及如何配置轮询计数，这里。
所以当我使用 Flux ?
下面是我的消费代码。

@Bean
    fun consumerInboundMsg(handler: QueueHandler): java.util.function.Function<Flux<MessageRequest>, Mono<Void>> {
        return Function { flux ->
            flux.asFlow().flatMapMerge {
                flow {
                    handler.handleInboundRequest(it)
                    emit(it)
                }
            }.asFlux().then()
        }
    }