Kubernetes kafka系列 | Strimzi 部署kafka-bridge

Strimzi +kafka集群部署直通车
一、kafka bridge 介绍
Kafka Bridge 是 Apache Kafka 生态系统中的一个工具或组件，用于实现 Kafka 与其他系统或协议之间的通信或集成。Kafka 本身是一个分布式事件流平台，广泛用于构建实时数据流水线和流式应用程序。然而，并非所有系统或应用程序都可能与 Kafka 的协议兼容或直接交互。

Kafka Bridge 充当中介或适配器，允许非 Kafka 应用程序与 Kafka 集群进行通信。它通常提供以下功能：

协议转换：将来自 Kafka 协议的消息转换为目标系统理解的另一种协议，反之亦然。
API 端点：公开 HTTP 或其他网络端点，供非 Kafka 应用程序与 Kafka 交互。
安全集成：实施身份验证和授权等安全措施，以访问 Kafka。
负载均衡：将外部应用程序的传入请求分发到多个 Kafka broker 上。
监控与管理：提供用于监控 Kafka Bridge 本身以及与 Kafka 集群的连接的健康状况和性能的工具。
通过使用 Kafka Bridge，组织可以将 Kafka 与各种系统、数据库或应用程序集成，而无需直接支持 Kafka 的协议，从而实现更灵活、可扩展的数据架构。

通过http接口来生产和消费kafka消息
官网：kafka bridge

二、部署

kafka-bridge.yaml

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaBridge
metadata:
  name: my-bridge
spec:
  replicas: 3
  bootstrapServers: my-cluster-kafka-bootstrap:9092   #kafka service
  http:
    port: 8080
1
2
3
4
5
6
7
8
9

bridge-service-nodeport.yaml

apiVersion: v1
kind: Service
metadata:
  name: bridge-nodeport
spec:
  type: NodePort
  ports:
  - port: 8080
    nodePort: 31331
  selector:
    strimzi.io/cluster: my-bridge
    strimzi.io/kind: KafkaBridge
    strimzi.io/name: my-bridge-bridge
1
2
3
4
5
6
7
8
9
10
11
12
13

curl -X GET http://10.10.101.166:31331/topics #根据地址和暴露端口就可以获取 topics

有建议请留言