在Ubuntu上配置Kafka生產者時,有一些關鍵的技巧和最佳實踐可以幫助你優化生產者的性能和數據傳輸的可靠性。以下是一些有用的配置項和步驟:
host1:port1,host2:port2
。org.apache.kafka.common.serialization.StringSerializer
。gzip
、snappy
、lz4
和zstd
。0
(不等待確認)、1
(等待leader副本確認)、all
(等待所有ISR副本確認)。以下是一個簡單的Kafka生產者配置示例:
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");
props.put("batch.size", "32768");
props.put("linger.ms", "5");
props.put("compression.type", "snappy");
KafkaProducer<String, String> producer = new KafkaProducer<>(props);