[jira] [Resolved] (KAFKA-19119) Move ApiVersionManager/SimpleApiVersionManager

[ https://issues.apache.org/jira/browse/KAFKA-19119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-19119. Fix Version/s: 4.1.0 Resolution: Fixed > Move ApiVersionManager/SimpleApiVersionMan

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

hi Colin Adding the config is a cool idea. However, the config will force us to maintain both behaviors in 5.0. Additionally, we need a complete deprecation cycle to remove the config. Maybe another alternative is to introduce a flag called “enable.unrelased.behavior”, allowing users to “test”

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

Hey Colin, > How about something like this? > 10 = fenced > 20 = controlled shutdown > 30 = active Yeah, that seems reasonable to me. Thanks for the suggestion. Kevin On Mon, Apr 14, 2025 at 12:42 PM Kevin Wu wrote: > Thanks for the comments Federico. > > > If I understand correctly unfence

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

See

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

Hi Kevin, The values for kafka.controller:type=KafkaController,name=BrokerRegistrationState seem a bit unintuitive. Using 0 for active might be confusing to systems that treat metrics that aren't present as 0. Or to people just scanning the graph visually. How about something like this? 10

Re: KIP-1155: Metadata Version Downgrades [DISCUSS]

On Fri, Apr 11, 2025, at 08:35, Andrew Schofield wrote: > Hi Colin, > Thanks for the KIP. > Hi Andrew. Thanks for looking at the KIP. > AS1: I think that the KIP is not going to prove that useful because of > the introduction of new features as > the recent releases have occurred. I'll give a co

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

I would suggest adding a configuration key which controls whether the null values are added. That configuration key can default to true in 4.x and false in 5.x. This will give people a chance to test the new behavior before 5.x. best, Colin On Fri, Mar 14, 2025, at 04:30, 黃竣陽 wrote: > Hello eve

Re: Requesting permission to contribute to Apache Kafka

Thanks for the Jira access, Luke! ☺️ Regards Divya On Mon, Apr 14, 2025 at 8:07 AM Luke Chen wrote: > Hi Divya, > > Your account should be all set. > > Thanks. > Luke > > On Sat, Apr 12, 2025 at 7:25 PM Divya Guduru > wrote: > > > I have access to the JIRA > > board but cannot assign issues to

Re: [VOTE] KIP-1143: Deprecated Optional and return String from public Endpoint#listenerName

Hi all, Thanks for your voting and participation. The KIP-1143 has been accepted with 3 binding +1 from Chia-Ping Tsai, Andrew Schofield, and TengYao Chi. Also, getting 3 non-binding +1 from Kirk True, 黃俊陽, and Federico Valeri. Thanks for everyone. Regards, PoAn > On Apr 11, 2025, at 8:11 PM,

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

Thanks for the comments Federico. > If I understand correctly unfenced == active. In the code we always > use the term active, so I think it would be better to use that for the > state 0 description. I've updated the KIP description to refer to "active". > You propose creating per-broker metrics

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

Thanks for the comments Jose. For 1 and 2, I've changed the naming of the metrics to follow your suggestion of tags/attributes. For 3, I made a note as to why we need the maximum. Basically, it's because the map that contains broker contact times we're using as the source for these metrics removes

[jira] [Resolved] (KAFKA-19121) Move AddPartitionsToTxnConfig, TransactionStateManagerConfig, and QuorumConfig out of KafkaConfig

[ https://issues.apache.org/jira/browse/KAFKA-19121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-19121. Fix Version/s: 4.1.0 Resolution: Fixed > Move AddPartitionsToTxnConfig, Transaction

[jira] [Created] (KAFKA-19137) Use `StandardCharsets.UTF_8` instead of `StandardCharsets.UTF_8.name()`

Chia-Ping Tsai created KAFKA-19137: -- Summary: Use `StandardCharsets.UTF_8` instead of `StandardCharsets.UTF_8.name()` Key: KAFKA-19137 URL: https://issues.apache.org/jira/browse/KAFKA-19137 Project:

Re: [VOTE] KIP-877: Mechanism for plugins and connectors to register metrics

Hi, There is an improvement in KIP-877. There will be an update to the PluginMetrics#metricName method: the type of the tags parameter will be changed from Map to LinkedHashMap. This change is necessary because the order of metric tags is important 1. If the tag order is inconsistent, identic

[jira] [Created] (KAFKA-19142) TestKitNodes doesn't bootstrap KIP-853 correctly

José Armando García Sancio created KAFKA-19142: -- Summary: TestKitNodes doesn't bootstrap KIP-853 correctly Key: KAFKA-19142 URL: https://issues.apache.org/jira/browse/KAFKA-19142 Project:

[jira] [Resolved] (KAFKA-19113) Migrate DelegationTokenManager to server module

[ https://issues.apache.org/jira/browse/KAFKA-19113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-19113. Fix Version/s: 4.1.0 Resolution: Fixed > Migrate DelegationTokenManager to server m

[jira] [Resolved] (KAFKA-19102) Enhance the docs of group.coordinator.append.linger.ms

[ https://issues.apache.org/jira/browse/KAFKA-19102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TengYao Chi resolved KAFKA-19102. - Fix Version/s: 4.1.0 Resolution: Fixed > Enhance the docs of group.coordinator.append.lin

[jira] [Resolved] (KAFKA-19027) Replace ConsumerGroupCommandTestUtils#generator by ClusterTestDefaults

[ https://issues.apache.org/jira/browse/KAFKA-19027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-19027. Fix Version/s: 4.1.0 Resolution: Fixed > Replace ConsumerGroupCommandTestUtils#gene

Re: EmbeddedConnectCluster with multiple Connectors

Hi Claude, Please see the methods on the Embedded connect class, #configureConnector(String, Map) and similar. If you specify different connector IDs, this will create multiple concurrent connectors. Thanks, Greg On Mon, Apr 14, 2025, 7:45 AM Claude Warren, Jr wrote: > Greetings, > > I am look

EmbeddedConnectCluster with multiple Connectors

Greetings, I am looking to run the EmbeddedClusterConnect with 2 different Connectors in an effort to prove round trip processing across a sink and a source connector. However, I don't see any way to create 2 different connectors within the cluster. Am I missing something or has this just not be

Re: [VOTE] KIP-1142: Allow to list non-existent group which has dynamic config

Hi PoAn, Thanks for the KIP. +1 (binding) Andrew From: PoAn Yang Sent: 08 April 2025 09:00 To: dev@kafka.apache.org Subject: [VOTE] KIP-1142: Allow to list non-existent group which has dynamic config Hi all, I would like to start a vote on KIP-1142. T

Re: [DISCUSS] KIP-1142: Allow to list non-existent group which has dynamic config

Hi Andrew, Thanks for the review. AS6: Add section about deprecating ListClientMetricsResourcesOptions. AS7: Add section about replacing ApiKeys.LIST_CLIENT_METRICS_RESOURCES with ApiKeys.LIST_CONFIG_RESOURCES. Thanks for the reminder. Regards, PoAn > On Apr 12, 2025, at 12:10 AM, Andrew Scho

[jira] [Created] (KAFKA-19139) Plugin#wrapInstance should use LinkedHashMap instead of Map

黃竣陽 created KAFKA-19139: --- Summary: Plugin#wrapInstance should use LinkedHashMap instead of Map Key: KAFKA-19139 URL: https://issues.apache.org/jira/browse/KAFKA-19139 Project: Kafka Issue Type: Impro

[jira] [Created] (KAFKA-19138) Kafka service is continuously restarting in one of the nodes in 3 node cluster

Sravani created KAFKA-19138: --- Summary: Kafka service is continuously restarting in one of the nodes in 3 node cluster Key: KAFKA-19138 URL: https://issues.apache.org/jira/browse/KAFKA-19138 Project: Kafka