rx connectors should be able to share a curator
darkone23 opened this issue · 1 comments
darkone23 commented
If you want to make a bunch of different consumers in different threads, they will all get their own instances of the curator framework and start their own zookeeper sessions.
This is not ideal, since the curator framework is safe for concurrent access we should be able to provide a single instance to all of our threads.
This improvement would likely be some simple changes to https://github.com/cjdev/kafka-rx/blob/master/src/main/scala/com/cj/kafka/rx/RxConnector.scala
darkone23 commented