ProducerRecord指定要發送到Kafka集群的鍵/值對,使用以下語法- .
public ProducerRecord(字符串主題,int分區,k鍵,v值)
在這裏,topic對應於用戶定義的主題名
Partition指分區數
鍵是記錄中包含的值
Value指記錄內容
下麵是使用ProducerRecord類構造函數-創建帶有鍵、值對且不帶分區的記錄的語法
public ProducerRecord(字符串主題,k鍵,v值)
下麵是用於創建沒有分區和鍵-的記錄的語法
public ProducerRecord(字符串主題,值)
下麵列出了一些ProducerRecord類方法的示例
- 公共字符串topic()
向記錄中添加主題
- 分區()
將分區計數添加到記錄中
- 公鑰()
要包含在記錄中的鍵值。如果沒有鍵,這裏將返回NULL,這意味著發送的數據沒有鍵。
- 公共V值()
記錄內容