Does this really address the respective problem? Ultimate task is that, the connection between broker and subscriber should not be terminated. Subscriber is free to change his topic interests without closing the connection.
On Wed, Nov 2, 2016 at 12:43 PM, Gerrit Jansen van Vuuren < gerrit...@gmail.com> wrote: > Hi, > > Have a look at the kafka client lib > https://github.com/gerritjvv/kafka-fast#java-1, it already provides this > functionality. > > > On Wed, Nov 2, 2016 at 2:34 AM, Janagan Sivagnanasundaram < > janagan1...@gmail.com> wrote: > > > Kafka's current nature is does not support to dynamic subscriber > > environment where the topic interest of the subscriber is keep change > > overtime unless subscriber terminate the particular connection and > > reconnect. > > > > What I have planned to implement or design is to enable the dynamic > > subscriber environment where the subscriber can change his topic > interests > > without terminating the connection with it's broker. Following are some > > ideas that we can use to do such thing. > > > > 1) Modifying the current protocol by adding an extra attribute > > 2) Create a control connection channel from subscriber to broker > > > > Is there easy/efficient way to do such thing? > > >
