Kafka是删除记录还是只移动偏移量?
Kafka采用的是日志压缩(Log Compaction)的方式来管理消息存储,而不是简单地删除记录或仅仅移动偏移量。以下是关于Kafka如何处理消息存储的详细解释:
以下是一个简单的Kafka生产者示例,演示如何发送消息到Kafka主题:
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import java.util.Properties;
public class KafkaProducerExample {
public static void main(String[] args) {
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
KafkaProducer<String, String> producer = new KafkaProducer<>(props);
for (int i = 0; i < 100; i++) {
producer.send(new ProducerRecord<>("my-topic", Integer.toString(i), "message-" + i));
}
producer.close();
}
}
请注意,上述代码和参考链接仅供参考,实际使用时可能需要根据具体需求进行调整。
领取专属 10元无门槛券
手把手带您无忧上云