操作Kafka配置靠得住的高机能漫衍式动静转达基本架构

适配器行使来自 Kafka 重试主题的动静，并对其举办从头处理赏罚。超出已设置的动静处理赏罚重试次数后，该适配器会将此动静转达到 Kafka 死信主题。发送到死信主题的动静包括有代价的营业数据，因此监督该主题至关重要。

传出流

传出流暗示由企业应用措施提倡的 Kafka 通讯。在我们的例子中，这是用于向移动应用措施发送付出确认的关照体系。JCA 类型界说了一个毗连打点合约，可让应用措施处事器归并 Kafka 毗连，从而提供支持大量客户端的可扩展情形。

Kafka 传出毗连设置具体信息是行使 Managed Connection Factory JavaBean 举办界说的。操作这些设置具体信息，打点员和开拓者可行使适配器来设置 Kafka 出产者，并抉择所需的成果，譬喻，靠得住性、可用性、吞吐量、耽误和事宜支持。这些设置具体信息将作为应用措施处事器设置的一部门来举办界说。

Kafka JCA 资源适配器将果真用于实验民众客户端接口 (CCI) 和 Java 动静处事 (JMS) 接口的 Kafka Connection Factory 和 Kafka Connection。应用措施组件会行使 Java 定名和目次接口 (JNDI) 名称来查找毗连工场。乐成获取毗连工场后，应用措施会行使它来获取毗连，以便会见 Kafka。这样，您就可觉得关照体系应用措施无缝添加 Kafka 集成，该应用措施当前将数据发送到 JMS 动静转达提供措施(如 IBM MQ 或 Active MQ)。

资源适配器传出流会封装初级此外 Kafka 通讯逻辑，并提供：

• 毗连归并
• 行使 Kafka 事宜性机制来担保仅转达一次
• 回收稳妥的方法来辨认、记录和处理赏罚 Kafka 妨碍
• 实验 XA 事宜，从而在漫衍式体系中通过 Kafka 提供靠得住的动静处理赏罚

要在传出流中打点事宜，Kafka 资源适配器可行使由 JCA 类型界说的事宜打点合约。

在我们的例子中，毗连工场必要配置为支持 XA 事宜，该适配器必要在客户端获取毗连时启动 Kafka 事宜。无论应用措施处事器何时回滚 Kafka 事宜，该事宜城市非常终止。假如产生 XA 事宜落实，那么事宜打点器会在正在运行的事宜所行使的全部资源上执行两阶段落实协议。这可担保对受管资源的全部读写会见官僚么所有落实，要么所有回滚。

最后，该资源适配器会通过向 Kafka 事宜日记主题写入事宜数据来跟踪正在运行的事宜。写入事宜日记主题的数据将用于瓦解规复处理赏罚，以便在漫衍式体系中提供靠得住的动静处理赏罚。

竣事语

Kafka JCA 适配器的计划要领为尺度企业 Java 办理方案提供了 JMS 与 Kafka 变乱处理赏罚平台的"即插即用式"集成。此计划支持将 Kafka 与现有企业应用措施无缝集成，而无需实验赔偿逻辑。通过该适配器，应用措施处事器还可以提供企业应用措施所依靠的基本架构和运行时情形，以用于成立 Kafka 毗连并执行事宜打点。

（编辑：河北网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!