Kirk True

*More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of testing...

*More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of testing...

KAFKA-16231: Update consumer_test.py to support KIP-848’s group protocol config

1

Added a new optional `group_protocol` parameter to the test methods, then passed that down to the `setup_consumer` method. Unfortunately, because the new consumer can only be used with the new...

[WIP] KAFKA-14830: Illegal state error in transactional producer

1

WIP ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation...

KAFKA-17439: Make polling for new records an explicit action/event in the new consumer

2

Updated the `FetchRequestManager` to only create and enqueue fetch requests when signaled to do so by a `FetchEvent`. The application thread and the background thread each contains logic that is...

KAFKA-16985: Ensure consumer sends leave request on close even if interrupted

42

The consumer should attempt to leave the group cleanly upon `close()`, regardless of a) the timeout, b) interrupts. If the user interrupted the current thread, upon `close()`, note the interruption,...

Back-port KAFKA-16230 to 3.7 branch

2

Back-porting changes for KAFKA-16230 to 3.7. Original change here: #15328. The Python VerifiableConsumer now passes in the --group-protocol and --group-remote-assignor command line arguments to VerifiableConsumer if the node is running...

KAFKA-17686: AsyncKafkaConsumer.offsetsForTimes() fails with NullPointerException

4

The code to convert the `Map` was initially expressed using the Streams API with `collect(Collectors.toMap())`. Unfortunately, the implementation of `Collector` returned by `Collectors.toMap()` does not support `null` entries. The `KafkaConsumer.offsetsForTimes()`...

Attempting ugly workaround ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ]...

KAFKA-17337: ConsumerConfig should default to CONSUMER for group.protocol

1

Updated `DEFAULT_GROUP_PROTOCOL` to use `CONSUMER` instead of `CLASSIC`, updated `GROUP_PROTOCOL_DOC` to be a little more flexible going forward, and cleaned up unit tests that assumed `CLASSIC` as the default group...