Kafka: 消息从主题中消失，最大时间=0。

要解决Kafka中消息从主题中消失的问题，并设置最大时间为0，可以使用以下代码示例：

import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.common.TopicPartition;

import java.util.Collections;
import java.util.Properties;

public class KafkaMessageConsumer {
    public static void main(String[] args) {
        // 配置Kafka消费者
        Properties props = new Properties();
        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
        props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringDeserializer");
        props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringDeserializer");

        // 创建Kafka消费者实例
        KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);

        // 订阅主题
        String topic = "your_topic_name";
        consumer.subscribe(Collections.singletonList(topic));

        // 从最早的位置开始消费
        consumer.seekToBeginning(Collections.singletonList(new TopicPartition(topic, 0)));

        // 消费消息
        while (true) {
            ConsumerRecords<String, String> records = consumer.poll(1000);
            records.forEach(record -> {
                // 处理消息
                System.out.println("Received message: " + record.value());
            });
            
            // 设置最大时间为0，立即退出循环
            if (System.currentTimeMillis() >= 0) {
                break;
            }
        }

        // 关闭Kafka消费者
        consumer.close();
    }
}

请注意，上述代码假设您已经安装并运行了Kafka服务器，并将其设置为在本地主机上的默认端口9092上运行。您需要将"your_topic_name"替换为您实际的Kafka主题名称。

此代码示例创建了一个Kafka消费者，并订阅指定的主题。然后，它将消费者的偏移量设置为最早的位置，以确保从主题的开头开始消费消息。在每次轮询中，它将接收到的消息打印到控制台，并检查当前时间是否超过了设定的最大时间。如果超过了最大时间，它将立即退出循环并关闭消费者。

请根据您的实际需求进行适当的修改和调整。