Re: [VOTE] KIP-953: partition method to be overloaded to accept headers as well.

Hi Jack, +1 (binding) Some friendly, non-blocking suggestions: - IMO it's still worth specifying that the headers will be read-only; this clarifies the intended API contract both for reviewers of the KIP who haven't read the GitHub PR yet, and for developers who may leverage this new method -

Re: [VOTE] KIP-953: partition method to be overloaded to accept headers as well.

Hey jack , +1 (non binding) Sagar. On Sat, 12 Aug 2023 at 8:04 AM, Jack Tomy wrote: > Hey everyone, > > Please consider this as a gentle reminder. > > On Mon, Aug 7, 2023 at 5:55 PM Jack Tomy wrote: > > > Hey everyone. > > > > I would like to call for a vote on KIP-953: partition method to

Re: [VOTE] KIP-953: partition method to be overloaded to accept headers as well.

Hey everyone, Please consider this as a gentle reminder. On Mon, Aug 7, 2023 at 5:55 PM Jack Tomy wrote: > Hey everyone. > > I would like to call for a vote on KIP-953: partition method to be > overloaded to accept headers as well. > > KIP : >

Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #2093

See

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.5 #58

See Changes: -- [...truncated 285233 lines...] Gradle Test Run :streams:integrationTest > Gradle Test Executor 177 > VersionedKeyValueStoreIntegrationTest >

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #2092

See Changes: -- [...truncated 401822 lines...] [INFO] --- compiler:3.1:compile (default-compile) @ streams.examples --- [INFO] Changes detected - recompiling the module!

[GitHub] [kafka-site] jolshan merged pull request #537: MINOR: Add Lucas Bradstreet to committers

jolshan merged PR #537: URL: https://github.com/apache/kafka-site/pull/537 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [kafka-site] jolshan commented on pull request #537: MINOR: Add Lucas Bradstreet to committers

jolshan commented on PR #537: URL: https://github.com/apache/kafka-site/pull/537#issuecomment-1675403860 Hmm - you should be able to merge this too. If you don't you may want to check your permissions.  (See I merged my own -- https://github.com/apache/kafka-site/pull/473) But I

RE: [DISCUSS] KIP-942: Add Power(ppc64le) support

Hi Divij, 1.No the different versions of JVM don't work differently for power architecture. It will be sufficient if we just run it with the latest supported JDK (20) + latest supported scala (2.13) 2. The plan has been updated accordingly for rejected alternatives -Original Message-

[jira] [Resolved] (KAFKA-13197) KStream-GlobalKTable join semantics don't match documentation

[ https://issues.apache.org/jira/browse/KAFKA-13197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13197. - Fix Version/s: 3.6.0 3.5.2 Resolution: Fixed >

[jira] [Resolved] (KAFKA-15054) Add configs and logic to decide if rack aware assignment should be enabled

[ https://issues.apache.org/jira/browse/KAFKA-15054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hao Li resolved KAFKA-15054. Fix Version/s: 3.6.0 Resolution: Fixed > Add configs and logic to decide if rack aware assignment

[jira] [Resolved] (KAFKA-15025) Implement min-cost flow without balancing tasks for same subtopology

[ https://issues.apache.org/jira/browse/KAFKA-15025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hao Li resolved KAFKA-15025. Fix Version/s: 3.6.0 Resolution: Fixed > Implement min-cost flow without balancing tasks for same

[jira] [Resolved] (KAFKA-15027) Implement rack aware assignment for standby tasks

[ https://issues.apache.org/jira/browse/KAFKA-15027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hao Li resolved KAFKA-15027. Fix Version/s: 3.6.0 Resolution: Fixed > Implement rack aware assignment for standby tasks >

[jira] [Resolved] (KAFKA-15024) Add cost function for task/client

[ https://issues.apache.org/jira/browse/KAFKA-15024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hao Li resolved KAFKA-15024. Fix Version/s: 3.6.0 Resolution: Fixed > Add cost function for task/client >

[jira] [Resolved] (KAFKA-15023) Get rack information for source topic partitions for a task

[ https://issues.apache.org/jira/browse/KAFKA-15023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hao Li resolved KAFKA-15023. Fix Version/s: 3.6.0 Resolution: Fixed > Get rack information for source topic partitions for a

Re: [DISCUSS] KIP-955: Add stream-table join on foreign key

Matthias, I think that I clouded this discussion a bit with the possible 'fat' message requirement for the one specific use case that I worked on. Therefore I would like to take a step back and to focus just on the actual KIP-955 that only proposes to create a stream-table join on foreign key.

[jira] [Created] (KAFKA-15336) Connect plugin Javadocs should mention serviceloader manifests

Greg Harris created KAFKA-15336: --- Summary: Connect plugin Javadocs should mention serviceloader manifests Key: KAFKA-15336 URL: https://issues.apache.org/jira/browse/KAFKA-15336 Project: Kafka

Re: [DISCUSS] KIP-966: Eligible Leader Replicas

Hi Calvin, Thanks for the KIP! I'm still digesting it but I have two questions: > In the scenario raised in the motivation section, the server may receive ack=1 messages during T1 and advance High Watermark when the leader is the only one in ISR. To confirm, the current protocol allows

Re: [DISCUSS] KIP-714: Client metrics and observability

Hi Andrew, Thanks for picking this KIP up. I know you've started a vote, so these are unhelpfully late... sorry about that, but hopefully they're still useful. 1. "The Kafka Java client provides an API for the application to read the generated client instance id to assist in mapping and

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2091

See

Re: [VOTE] KIP-962 Relax non-null key requirement in Kafka Streams

+1(binding) On Fri, Aug 11, 2023 at 7:33 AM Lucas Brutschy wrote: > +1 (non-binding) > > On Fri, Aug 11, 2023 at 1:08 AM Matthias J. Sax wrote: > > > > +1 (binding) > > > > On 8/10/23 12:31 PM, Florin Akermann wrote: > > > >

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2090

See

Re: [VOTE] KIP-962 Relax non-null key requirement in Kafka Streams

+1 (non-binding) On Fri, Aug 11, 2023 at 1:08 AM Matthias J. Sax wrote: > > +1 (binding) > > On 8/10/23 12:31 PM, Florin Akermann wrote: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-962%3A+Relax+non-null+key+requirement+in+Kafka+Streams > >

[jira] [Created] (KAFKA-15335) Support custom SSL configuration for Kafka Connect RestServer

Taras Ledkov created KAFKA-15335: Summary: Support custom SSL configuration for Kafka Connect RestServer Key: KAFKA-15335 URL: https://issues.apache.org/jira/browse/KAFKA-15335 Project: Kafka

Re: What are the biggest issues with Apache Kafka?

Hey Liam Thanks for asking this question. I have been meaning to write a post to the community for a long time about potential open areas where newcomers can contribute but it never made it to priority in my to-do list. In addition to what others mentioned above, here's a couple of options to

[jira] [Created] (KAFKA-15334) DescribeQuorum should not be seen as cluster action

Deng Ziming created KAFKA-15334: --- Summary: DescribeQuorum should not be seen as cluster action Key: KAFKA-15334 URL: https://issues.apache.org/jira/browse/KAFKA-15334 Project: Kafka Issue

Re: [DISCUSS] KIP-714: Client metrics and observability

Hi Doguscan, Thanks for your question. If the target broker is unreachable, the client can send the metrics to another broker. It can select any of the other brokers for this purpose. What I expect in practice is that it loses connection to the broker it’s being using for metrics, chooses or

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2089

See