You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2018/10/08 08:12:24 UTC

[GitHub] sijie opened a new pull request #2746: [clients][kafka] Fix topic name & race condition on kafka wrapper

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:
users@infra.apache.org


With regards,
Apache Git Services