Shivsundar R

*What* Added `ShareConsumerTest.java` for KafkaShareConsumers. We are using `KafkaClusterTestKit` for the integration tests.

*What* Currently in `ShareConsumeRequestManager`, after we receive a `ShareFetchResponse`, if the subscription changes before we acknowledge(via `ShareFetch`), then we do not acknowledge the records which are not part of the...

KAFKA-17853: Fix termination issue in ConsoleConsumer and ConsoleShareConsumer

6

https://issues.apache.org/jira/browse/KAFKA-17853 - - There is an issue with the console share consumer where if the broker is unavailable, even after force terminating using ctrl-c, the consumer does not shut down...