RE: Issue accessing apache.org

Hi All, Please let me know if anyone is working on this. If you are not the correct contact, please help with right contact. Thanks & Regards, Laxmikant Shete Sr. Network Systems Engineer Direct + 91-20-40175476 From: Shete, Laxmikant Sent: Sunday, May 9, 2021 5:05 PM To:

Re: Kafka Consumer Incremental Rebalance Protocol | Downgrade

Thank you, Sophie. It helps a lot. On Tue, May 11, 2021 at 11:58 PM Sophie Blee-Goldman wrote: > Hey Vipul, > > There's no "rebalance.protocol" config, as the protocol is determined by > the supported partition > assignors. The assignors can be configured with the config >

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

See

[jira] [Resolved] (KAFKA-12772) Move all TransactionState transition rules into their states

[ https://issues.apache.org/jira/browse/KAFKA-12772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dengziming resolved KAFKA-12772. Resolution: Fixed > Move all TransactionState transition rules into their states >

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

See

Jenkins build is back to normal : Kafka » kafka-2.7-jdk8 #153

See

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 2.8 #26

See

[DISCUSS] KIP-736: Report the real end to end fetch latency

Hi Kafka, I'd like to open up the discussion on a KIP-736. This is to report the "real" fetch latency by removing the effects of waiting due to replica.fetch.wait.max.ms or fetch.min.bytes in purgatory Please give it a look over and let me know what you think.

Re: [VOTE] KIP-730: Producer ID generation in KRaft mode

Closing this vote. With four binding +1s and zero -1s, this vote passes. Binding +1: * David Arthur * Guozhang Wang * Tom Bentley * Colin McCabe Non-binding +1: * Ron Dagostino Thanks everyone! David On Tue, May 11, 2021 at 1:07 PM Colin McCabe wrote: > Thanks, David. I don't feel strongly

Re: [DISCUSS] KIP-736: Removal of Connect's internal converter properties

Hi all, Due to some confusion this KIP's number conflicted with an existing one. I've renamed it to KIP-738. Given the tight scope of the proposed changes, I'm hoping to open a vote on this soon if there's no discussion to be had. Cheers, Chris On Wed, May 5, 2021 at 2:33 PM Chris Egerton

Re: Kafka Consumer Incremental Rebalance Protocol | Downgrade

Hey Vipul, There's no "rebalance.protocol" config, as the protocol is determined by the supported partition assignors. The assignors can be configured with the config "partition.assignment.strategy". I suspect the "rebalance.protocol" comment was a leftover from an older version of the proposal.

Re: [VOTE] KIP-730: Producer ID generation in KRaft mode

Thanks, David. I don't feel strongly about preserving the extra records in the snapshot, so let's just leave it as is. +1 (binding) cheers, Colin On Fri, May 7, 2021, at 09:51, David Arthur wrote: > Colin, thanks for the feedback. I like the record name you proposed. I've > also updated the

[jira] [Created] (KAFKA-12773) Use UncheckedIOException when wrapping IOException

Jose Armando Garcia Sancio created KAFKA-12773: -- Summary: Use UncheckedIOException when wrapping IOException Key: KAFKA-12773 URL: https://issues.apache.org/jira/browse/KAFKA-12773

[jira] [Resolved] (KAFKA-12758) Create a new `server-common` module and move ApiMessageAndVersion, RecordSerde, AbstractApiMessageSerde, and BytesApiMessageSerde to that module.

[ https://issues.apache.org/jira/browse/KAFKA-12758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-12758. - Fix Version/s: 3.0.0 Resolution: Fixed merged the PR to trunk > Create a new `server-common`

Re: KafkaStreams Scala: Replace FunctionsCompatConversions

Hey John Fork - Yes; That's what I did in my POC, but my colleagues didn't like it so much, because of the maintenance burden.. Contribute - by all means. I was hoping there's a means to avoid this low level change, but if I end up making it, then it eventually should be part of the library. I

Kafka Consumer Incremental Rebalance Protocol | Downgrade

Hi Team, I need some guidance related to Kafka Consumer Incremental Rebalance Protocol. I was following the below KIP and understood the upgrade path, But a bit confused with the downgrade procedure. *KIP:*

Re: KafkaStreams Scala: Replace FunctionsCompatConversions

Hi Rama, Ah, I think I see what you are getting at now. I thought you were trying to extend the implicits, But now I’m thinking that what you want is to extend KStream.scala, KTable.scala, etc. As you observed, those classes are final, but what you could do is basically replace it with your

Re: Reviews for https://github.com/apache/kafka/pull/10651

Hi Josep, Thank for the PR! Do not worry about the test failures. First of all, your PR does not touch any code, so there is no reason a test would fail due to your PR. Additionally, the failing tests are all known to be flaky. You can find known flaky tests in the JIRA by searching for the

Reviews for https://github.com/apache/kafka/pull/10651

Hi there, A couple of days ago I created a small documentation PR ( https://github.com/apache/kafka/pull/10651), just fixing some formatting for sample code listings, but unfortunately, tests were failing. The changes in the PR (As they are only on html pages, should have no effect on the tests

[jira] [Created] (KAFKA-12772) Move all TransactionState transition rules into their states

dengziming created KAFKA-12772: -- Summary: Move all TransactionState transition rules into their states Key: KAFKA-12772 URL: https://issues.apache.org/jira/browse/KAFKA-12772 Project: Kafka