Gyeongwon, Do

Allow configuration for ID Token time-to-live

2

**Expected Behavior** Should allow different clients to customize different ID Token TTL. **Current Behavior** The ID Token TTL is always 30 minutes. **Context** In JwtGenerator.java ``` Instant issuedAt = Instant.now();...

While reading the Consumer code, I found that the code and comment did not match. I have created a PR to fix this inconsistency. ### Committer Checklist (excluded from commit...

MINOR: clear inFlightCorrelationId when ConnectionState is changed to READY

1

When a request is timed out, a old inFlightCorrelationId value is remaining

MINOR: Remove unused controlPlaneRequestProcessor in BrokerServer.

3

In BrokerServer, controlPlaneRequestProcessor is always null and is not used. In addition, `validateControlPlaneListenerEmptyForKRaft` in `KafkaConfig` checks that `controlPlaneListenerName` is empty in KRaft mode. So, controlPlaneRequestProcessor is not needed in BrokerServer...

KAFKA-15615: Improve handling of fetching during metadata updates

8

# Problem As stated in the [KAFKA-15615](https://issues.apache.org/jira/projects/KAFKA/issues/KAFKA-15615) When a fetch response receives an error about partition leadership, fencing, etc. a metadata refresh is triggered. Until its metadata is updated, the...

DRAFT KAFKA-18692: Consider to unify KStreamImpl "repartitionRequired" with GraphNode "keyChangingOperation"

10

That PR is a POC. For now, I only focused on modifying `KStreamImpl.repartitionRequired` to replace it with `GraphNode.keyChangingOperation`. So I'll be working on it further to make sure it's the...

What ---- Add deprecated notices to README for channel-based produce Checklist ------------------ - [ ] Contains customer facing changes? Including API/behavior changes - [ ] Did you add sufficient unit...