如何使用camel-kafka手动控制偏移量提交？

import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.kafka.KafkaManualCommit;
import org.apache.camel.component.kafka.KafkaConstants;

public class KafkaConsumerRoute extends RouteBuilder {
    @Override
    public void configure() throws Exception {
        from("kafka:{{kafka.topic}}?brokers={{kafka.brokers}}&groupId={{kafka.groupId}}")
            .process(exchange -> {
                // 处理消息的逻辑
                String message = exchange.getIn().getBody(String.class);
                System.out.println("Received message: " + message);
                
                // 手动提交偏移量
                KafkaManualCommit manualCommit = exchange.getIn().getHeader(KafkaConstants.MANUAL_COMMIT, KafkaManualCommit.class);
                if (manualCommit != null) {
                    manualCommit.commitSync();
                }
            });
    }
}