不同Kubernetes集群上的Kafka生产者和消费者

Question

Kafka需要安装在消费者集群上吗?

目前相同的集群YAML配置为:

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
name: sample-topic
spec:
type: bindings.kafka
version: v1
metadata:
# Kafka broker connection setting
- name: brokers
value: dapr-kafka.kafka:9092
# consumer configuration: topic and consumer group
- name: topics
value: sample
- name: consumerGroup
value: group1
# publisher configuration: topic
- name: publishTopic
value: sample
- name: authRequired
value: "false"

在不同的集群上，每个集群是否只需要"name: publishTopic"名称:consumerGroup"而不是另一个?

Answer 1

我不熟悉Dapr，但Kafka不需要安装在k8s或任何特定位置。您唯一的要求应该是客户端连接到该引导服务器列表。

根据Kafka绑定规范，consumerGroup用于传入事件，publishTopic用于传出事件，所以这是两种不同的用例，尽管一个应用程序应该能够拥有这两种事件类型。如果应用只使用传入或传出事件，那么就使用相应的绑定。