我有一个生产者，生产特定主题的消息：
制作人：

// Produce a message to a Kafka topic
        String topic = "dev.topic.proxy";
        String key = "some-key";
        String value = "Hello, Kafka!";

        ProducerRecord<String, String> record = new ProducerRecord<>(topic, key, value);

        while (true) {
            producer.send(record);
            System.out.println("Message has been sent");
        }

字符串

消费者：

<routes xmlns="http://camel.apache.org/schema/spring">
    <route id="readMsg">
        <description>Route to refresh the proxy routes</description>
       <from uri="appKafkaConsumer:dev.topic.proxy" />
        <log message="Received message with headers: ${headers}" loggingLevel="INFO" />
        <delay>
        <constant>5000</constant>
    </delay>
    </route>
</routes>

型
这是camel中的消费者。groupId是在我启动应用程序时随机自动生成的。我停止了应用程序，当我重新启动应用程序时，由于分配了新的groupId，许多消息丢失。我不想丢失消息。什么是最好的解决方法？