oudb commented on issue #286: URL: https://github.com/apache/rocketmq-connect/issues/286#issuecomment-1226708939
the concept of Partition in Rocketmq is MessageQueue(topic,brokerName,queueId)，but in Kafka is TopicPartition(topic，partition)，we need some method to encode brokerName to TopicPartition：topic or partition. this is import for adapting Kafka sink connector, because sink connector will call the org.apache.kafka.connect.sink.SinkTaskContext,then will lost brokerName. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: dev-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
