Kafka之Java生产者是如何管理TCP连接的

      最后更新:2022-05-24 08:33:04 手机定位技术交流文章

      TCP用于卡夫卡的所有通信。它不是基于HTTP或任何其他协定。不仅仅是生产者和消费者; 也关系到那些个人 他们不知道自己在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么,他们在做什么或经纪人之间的相互作用。为什么卡夫卡不使用HTTP作为其主要通讯协议?这是由于各种因素造成的。根本原因是TCP和HTTP之间的区别。在开发客户端时,个人可以利用TCP提供的一些尖端功能加以利用。例如,许多访问请求和同时连接轮调。

      卡夫卡生产者进程概览

      Kafka制作人主要针对Kafka的爪哇生产者API。

      何时创建TCP连接

      1. 在建立 " Kafka生产者 " 的例子时,生产者应用软件被用来与中间商建立TCP联系。事实上,它远非准确。应当指出,在发展卡夫卡生产者的例子时,在后台, 制片人应用程序生成并开始一个线索, 叫做发件人 。发件人线索从连接布洛克线索开始

      制片人如何知道在不使用 Send 方法的情况下传播哪个主题, 或他与谁有联系, 或他与谁有联系? 服务器参数中指定了所有经纪人 。

      抱歉, 靴子陷阱。 服务器参数 : 此制片人以您想要连接到的 Broker 地址开始 。“启动时”,与这些经纪人的联系将在生产者开始时代表生产者开始。因 此,如果您为此选项输入 1 00 个 Broker 连接细节, 那么很遗憾,你的制片人将首先建立 TCP 连接到100个经纪人。

      2. 也可以在两个点建立TCP连接:更新元数据和传送信息。

      何时关闭TCP连接

      第一个是用户故意关闭,第二个是卡夫卡自动关闭。

      本文由 在线网速测试 整理编辑,转载请注明出处,原文链接:https://www.wangsu123.cn/news/26048.html

          热门文章

          文章分类