卡夫卡

ProducerRecord API

ProducerRecord API

ProducerRecord指定要發送到Kafka集群的鍵/值對,使用以下語法- .

public ProducerRecord(字符串主題,int分區,k鍵,v值)

在這裏,topic對應於用戶定義的主題名

Partition指分區數

鍵是記錄中包含的值

Value指記錄內容

下麵是使用ProducerRecord類構造函數-創建帶有鍵、值對且不帶分區的記錄的語法

public ProducerRecord(字符串主題,k鍵,v值)

下麵是用於創建沒有分區和鍵-的記錄的語法

public ProducerRecord(字符串主題,值)

下麵列出了一些ProducerRecord類方法的示例

  • 公共字符串topic()

向記錄中添加主題

  • 分區()

將分區計數添加到記錄中

  • 公鑰()

要包含在記錄中的鍵值。如果沒有鍵,這裏將返回NULL,這意味著發送的數據沒有鍵。

  • 公共V值()

記錄內容


DevOps景觀
2小時
初學者
642人注冊
3.6 (10)
SQL連接
2小時
初學者
2.5 k +人注冊
4.37 (63)
防火牆
1小時
初學者
6 k +人注冊
4.51 (283)
設計思考
1小時
初學者
3.7 k +人注冊
4.4 (281)
數據庫管理係統
1小時
初學者
6.9 k +人注冊
4.33 (374)
卓越運營和批判性思維
1小時
初學者
1.8 k +人注冊
4.49 (95)
net基礎
2小時
初學者
5.7 k +人注冊
4.44 (243)
net哦
1小時
初學者
2.1 k +人注冊
4.58 (73)
Python實踐代碼
1小時
初學者
2.7 k +人注冊
4.31 (107)
Excel中的VLOOKUP
1小時
初學者
11.5 k +人注冊
4.52 (394)
Baidu
map