Skip to main content
版本:Next

Kafka

KafkaSinkConnector:从 EventMesh 到 Kafka

  1. 启动你的 EventMesh Runtime。
  2. 启用 sinkConnector 并检查 sink-config.yml
  3. 启动你的 KafkaConnectServer,它将订阅到 EventMesh Runtime 中 pubSubConfig.subject 中定义的主题,并将收到的数据发布到 Kafka 中的 connectorConfig.topic
  4. 使用在 pubSubConfig.subject 中指定的 Topic,向 EventMesh 发送消息,然后你将在 Kafka 看到该消息。
# 公共配置
pubSubConfig:
meshAddress: 127.0.0.1:10000
subject: TopicTest
idc: FT
env: PRD
group: kafkaSink
appId: 5031
userName: kafkaSinkUser
passWord: kafkaPassWord
connectorConfig:
connectorName: kafkaSink
# kafka连接参数 ↓
bootstrapServers: 127.0.0.1:9092
topic: TopicTest
keyConverter: org.apache.kafka.common.serialization.StringSerializer
valueConverter: org.apache.kafka.common.serialization.StringSerializer

KafkaSourceConnector:从 Kafka 到 EventMesh

  1. 启动你的 EventMesh Runtime。
  2. 启用 sourceConnector 并检查 source-config.yml
  3. 启动你的 KafkaConnectServer,它将订阅 Kafka 的 connectorConfig.topic ,并将读取的数据发送到 EventMesh Runtime 中的 pubSubConfig.subject
  4. 向 Kafka 发送一个消息,然后你将在 EventMesh 中接收到该消息。
# 公共配置
pubSubConfig:
meshAddress: 127.0.0.1:10000
subject: TopicTest
idc: FT
env: PRD
group: kafkaSource
appId: 5032
userName: kafkaSourceUser
passWord: kafkaPassWord
connectorConfig:
connectorName: kafkaSource
# kafka连接参数 ↓
bootstrapServers: 127.0.0.1:9092
topic: TopicTest
groupID: kafkaSource
sessionTimeoutMS: 10000
maxPollRecords: 1000