search

apache / pulsar-adapters

Apache Pulsar Adapters
https://pulsar.apache.org/
24 stars 31 forks source link

[improve] Kafka adaptor - Handle partition topic. #37

Closed casuallc closed 1 year ago

casuallc commented 2 years ago

When consumer subscribe partitioned topic, messae id is TopicMessageIdImpl but not MessageIdImpl.