*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

[ Full content available at: https://github.com/apache/pulsar/pull/2746 ]
This message was relayed via gitbox.apache.org for devnull@infra.apache.org

Reply via email to