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? >
