我是kafka的新手，我使用javaapachecamel库实现了一个kafka消费者。我发现的问题是——消费者花了很长时间（>15分钟）来处理很少的消息——这对于我们的用例来说很好。
需要一些配置帮助，因为如果在15分钟内没有处理同一条消息，则该消息将在15分钟后重新发送（我相信线程控制不会返回）。我想这可能是默认间隔，不确定这是哪个属性。
那么，我要在哪里修复配置呢
生产者级别，以便它不重新发送
或者生产者不参与重新发送，它是代理-Kafka服务器，所以消费者必须确认消息-在我的情况下，就在处理之前。
我的制作人有以下特点：

<entry key="bootstrap.servers" value="${kafka.bootstrap.servers}" />
       <entry key="key.serializer" value="org.apache.kafka.common.serialization.StringSerializer" />
       <entry key="value.serializer" value="org.apache.kafka.common.serialization.StringSerializer" />

我的消费者看起来像

<endpoint id="apolloKafkaJanitorEventListenerURI"
            uri="kafka:${kafka.bootstrap.servers}?topic=${apollo.janitor.event.topic}&amp;
                                                        groupId=${apollo.janitor.event.group.id}&amp;
                                                        consumersCount=${apollo.janitor.event.consumer.count}&amp;
                                                        consumerRequestTimeoutMs=${eventConsumerRequestTimeoutMs}&amp;
                                                        sessionTimeoutMs=${eventConsumerSessionTimeoutMs}&amp;
                                                        maxPartitionFetchBytes=${eventConsumerMaxPartitionFetchBytes}" />

我在谷歌上搜索过，没有发现任何相关问题。在producer和consumer上找到“acks=0”属性，如下所示。还没有测试，但想先看看我是否在正确的轨道上

KafkaManualCommit manual =
       exchange.getIn().getHeader(KafkaConstants.MANUAL_COMMIT, KafkaManualCommit.class);
   manual.commitSync();

https://github.com/apache/camel/blob/master/components/camel-kafka/src/main/docs/kafka-component.adoc