Kafka ProducerRecord是Kafka Producer發送消息到Kafka集群時所使用的一個類
key:消息的鍵(Key),用于將相同鍵的消息發送到同一個分區,從而提高消息的有序性。key可以是null,如果不需要指定key,那么Kafka會自動生成一個UUID作為key。
value:消息的值(Value),即實際要發送的數據。value可以是null,也可以是任意類型的數據,如字符串、字節數組等。
topic:消息所屬的topic,用于指定消息要發送到的Kafka主題。
partition:消息要發送到的分區,用于實現負載均衡和并行處理。如果未指定partition,Kafka會自動選擇一個可用的分區。
headers:消息的元數據(Headers),用于傳遞一些額外的信息,如鍵值對形式的元數據。
timestamp:消息的時間戳(Timestamp),用于記錄消息發送的時間。如果未指定timestamp,Kafka會使用當前時間作為默認值。
callback:發送消息后的回調函數,用于在消息發送成功或失敗時執行相應的操作。
通過創建一個Kafka ProducerRecord對象,你可以將需要發送的消息和相關屬性配置好,然后調用Kafka Producer的send()方法將消息發送到Kafka集群。