如何在一个集群中配置kafka broker发布消息答案

【问题标题】：How to configure a kafka broker in one cluster to publish message如何在一个集群中配置kafka broker发布消息
【发布时间】：2023-02-01 03:15:19
【问题描述】：

我有两个经纪人，我想用特定区域的特定消息限制第二个经纪人。
例如，我们在世界上有多个地区提供我们的服务，如中国、印度
我只是想将印度地区的特定合作伙伴数据转移到 broker1，将中国地区的特定合作伙伴数据转移到 broker2。
如果可能的话，我正在寻找需要在 C# 中实现的解决方案，但欢迎提出想法。

我有这样的初始配置

`"Kafka": {`
    `"Address": "[\"localhost\"]",
`   ` "BrokerHosts": "[\"localhost:9092\"]",`
    `"BrokerHostsIndia": "[\"localhost:9094\"]",`
`}`

【问题讨论】：

标签： apache-kafka confluent-kafka-dotnet

【解决方案1】：

不太确定我理解这个问题。你这里的配置是为了集群，不是经纪人。

你可以做var bootstrapIndia = config.get("Kafka").get("BrokerHostsIndia")，然后在ProducerConfig中设置它以获得“印度地区”的生产者簇.

一个生产者不能一次发送到多个集群，所以你需要有一些Dictionary<string, IProducer>，然后为每个区域创建多个实例。

【讨论】：