2.2. 配置 Kafka Bridge 属性
这个步骤描述了如何配置 AMQ Streams Kafka Bridge 使用的 Kafka 和 HTTP 连接属性。
您可以使用针对 Kafka 相关属性的适当前缀,将 Kafka Bridge 配置为任何其他 Kafka 客户端。
-
Kafka.。对于适用于生产者和消费者的常规配置,如服务器连接和安全性。 -
Kafka.consumer.对于只传递给消费者的消费者特定配置。 -
Kafka.producer。用于传递给制作者的特定生产配置。
除了启用对 Kafka 集群的 HTTP 访问外,HTTP 属性提供通过 Cross-Origin Resource Sharing(CORS)启用和定义 Kafka Bridge 的访问控制的功能。CORS 是一种 HTTP 机制,它允许浏览器从多个来源访问所选资源。要配置 CORS,您可以定义允许的资源来源列表和 HTTP 方法来访问它们。请求中的其他 HTTP 标头描述了允许访问 Kafka 集群的 CORS 源。
先决条件
流程
编辑 AMQ Streams Kafka Bridge 安装存档提供的
application.properties文件。使用 属性文件来指定 Kafka 和 HTTP 相关属性,以及启用分布式追踪。
配置标准 Kafka 相关属性,包括特定于 Kafka 用户和制作者的属性。
使用:
-
Kafka.bootstrap.servers用于定义到 Kafka 集群的主机/端口连接 -
Kafka.producer.acks为 HTTP 客户端提供确认信息 Kafka
.consumer.auto.offset.reset以确定如何在 Kafka 中管理重置偏移有关配置 Kafka 属性的更多信息,请参阅 Apache Kafka 网站
-
配置 HTTP 相关属性,以启用对 Kafka 集群的 HTTP 访问。
例如:
Copy to Clipboard Copied! Toggle word wrap Toggle overflow