sijie opened a new pull request #2746: [clients][kafka] Fix topic name & race condition on kafka wrapper URL: https://github.com/apache/pulsar/pull/2746 *Motivation* Current PulsarKafkaConsumer has following defects: - topic name is used inconsistently for keeping different mapping. we should always use fully qualified topic name as keys for keeping mappings. - seek should clean up offset maps - poll logic can potentially pop a message but not deliver it to the client *Changes* - Fixes those issues in kafka wrapper - Enable kafka integration tests and use standalone test suite - Enable kafka client logging
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
