< Simple Producer示例
ProducerRecord API >
生產者類在Kafka中形成生產者API的中心部分，並幫助形成與Kafka代理的連接。
使用“send方法”，Producer類可以向一個或多個主題發送消息。這裏是語法-
public void send(KeyedMessaget
-將數據發送到單個主題，使用sync或async producer按鍵分區。
公共空間發送(列表< KeyedMessage < k、v > >消息)
-發送數據到多個主題。
Properties道具= new Properties();
prop.put (producer.type“異步”)
ProducerConfig config = new ProducerConfig(prop);
使用“關閉方法”可以確保所有與Kafka代理的連接都是關閉的。下麵是關閉方法-的語法
公共空間close ()
< Simple Producer示例
ProducerRecord API >
我們知道你已經申請了。
請注意，GL學院隻提供了Great learning的一小部分學習內容。beplay2018官网對於GL Excelerate的職業幫助和專職導師的完整項目體驗，我們的項目將是最適合你的。如有任何問題，請隨時聯係您的學習顧問。您可以通過訪問程序演示來體驗我們的程序。
我們看到你已經注冊了我們的
請注意，GL Academy隻提供了我們項目的一部分學習內容。由於您已經注冊進入我們的項目，請確保您的學習之旅繼續順利進行。我們會將您的偉大學習學院課程添加到beplay2018官网您的儀表板，您可以在儀表板上切換您的注冊課程和學院課程。
我們會將您的Great Learnbeplay2018官网ing Academy課程添加到您的儀表板中，您可以在儀表板中切換您的Digital Campus批次和GL Academy。
我們知道你感興趣。
作為我們pg課程的一部分，請確保您的學習之旅繼續順利進行。下载beplay体育
GL學院隻提供了我們pg課程的一部分學習內容，CareerBoost是GL學院為幫助大學生找到入門級工作而發起的一個項目。下载beplay体育
