Re: [DISCUSS] KIP-1140: Avoid to return null value in Map from public api of consumer

hi Matthias Thanks for offering this approach. I had considered proposing it before. My concern was the new/deprecated config is used by client, so it could cause a bunch of warning messages by default. Also, users have to add the new/deprecated config to each client properties if they want to

Re: [DISCUSS] KIP-1140: Avoid to return null value in Map from public api of consumer

That's right. Similar approach: https://lists.apache.org/thread/3fxqdsosm3z7xp4rr8db2qmyg5vd0v1b Ismael On Mon, Apr 21, 2025, 7:43 PM Matthias J. Sax wrote: > I don't think we would need a second deprecation cycle. > > Instead, we could add this new config, and deprecate it right away. This > w

Re: [DISCUSS] KIP-1140: Avoid to return null value in Map from public api of consumer

I don't think we would need a second deprecation cycle. Instead, we could add this new config, and deprecate it right away. This way, we can change the default behavior and remove the config both with 5.0. I guess the core question is really, do we want to enable the old or new behavior by de

Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #275

See

[jira] [Resolved] (KAFKA-19019) Verify Share Fetch with Tiered Storage

[ https://issues.apache.org/jira/browse/KAFKA-19019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-19019. - Fix Version/s: 4.1.0 Resolution: Fixed merged the PR to trunk > Verify Share Fetch with Tiered S

Re: [DISCUSS] KIP-1131: Controller-side monitoring for broker shutdown and startup

We had some offline discussion about this, so let me summarize. - States as strings really doesn't play well with Grafana, Datadog, New Relic and whatever else people are using with Kafka. - We might want to add more states in the future (like "never-unfenced", "post-controlled-shutdown", etc.)

Re: [DISCUSS] KIP-1161: cleanup.policy shouldn't be empty

Hi, Jiunn-Yang, Thanks for the KIP. A few comments. 1. It's fine to introduce a new value None for cleanup.policy. But now not all value combinations are valid. For example, None can't be used with Delete or Compact. It would be useful to document that. 2. What's the behavior during upgrade when

[jira] [Resolved] (KAFKA-19014) Potential race condition in remote-log-reader and remote-log-index-cleaner thread

[ https://issues.apache.org/jira/browse/KAFKA-19014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash resolved KAFKA-19014. -- Fix Version/s: 4.1.0 Assignee: Kamal Chandraprakash Resolution:

[jira] [Created] (KAFKA-19184) Document kraft version upgrade

José Armando García Sancio created KAFKA-19184: -- Summary: Document kraft version upgrade Key: KAFKA-19184 URL: https://issues.apache.org/jira/browse/KAFKA-19184 Project: Kafka Is

[jira] [Created] (KAFKA-19183) Move Pool and PoolTest to server module

PoAn Yang created KAFKA-19183: - Summary: Move Pool and PoolTest to server module Key: KAFKA-19183 URL: https://issues.apache.org/jira/browse/KAFKA-19183 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-8830) KIP-512: make Record Headers available in onAcknowledgement

[ https://issues.apache.org/jira/browse/KAFKA-8830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-8830. --- Fix Version/s: 4.1.0 Resolution: Fixed > KIP-512: make Record Headers available in onA

[jira] [Created] (KAFKA-19182) Move SchedulerTest to server module

Chia-Ping Tsai created KAFKA-19182: -- Summary: Move SchedulerTest to server module Key: KAFKA-19182 URL: https://issues.apache.org/jira/browse/KAFKA-19182 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-18933) Add integration tests for :clients outside of :core

[ https://issues.apache.org/jira/browse/KAFKA-18933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18933. Fix Version/s: 4.1.0 Resolution: Fixed > Add integration tests for :clients outside

[jira] [Resolved] (KAFKA-19180) Fix the hanging testPendingTaskSize

[ https://issues.apache.org/jira/browse/KAFKA-19180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamal Chandraprakash resolved KAFKA-19180. -- Fix Version/s: 4.1.0 Resolution: Fixed > Fix the hanging testPendingTas

[jira] [Created] (KAFKA-19181) Investigate system test failures

Chirag Wadhwa created KAFKA-19181: - Summary: Investigate system test failures Key: KAFKA-19181 URL: https://issues.apache.org/jira/browse/KAFKA-19181 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-19180) Fix the hanging testPendingTaskSize

Chia-Ping Tsai created KAFKA-19180: -- Summary: Fix the hanging testPendingTaskSize Key: KAFKA-19180 URL: https://issues.apache.org/jira/browse/KAFKA-19180 Project: Kafka Issue Type: Improveme