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?
