[DISCUSS] KIP-944 Support async runtimes in consumer

[This is a resend with the correct KIP number.] Hello developers of the Java based consumer, I submitted https://github.com/apache/kafka/pull/13914 to fix a long standing problem that the Kafka consumer on the JVM is not usable from asynchronous runtimes such as Kotlin co-routines and ZIO.

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

See Changes: -- [...truncated 485462 lines...] [Pipeline] echo Skipping Kafka Streams archetype test for Java 17 [Pipeline] } [Pipeline] // withEnv [Pipeline] } [Pipeline]

Re: [DISCUSS] KIP-759: Unneeded repartition canceling

Shay, thanks for picking up this KIP. It's a pity that the discussion stalled for such a long time. As expressed previously, I am happy with the name `markAsPartitioned()` and also believe it's ok to just document the impact and leave it to the user to do the right thing. If we really get

Re: [DISCUSS] KIP-941: Range queries to accept null lower and upper bounds

Thanks for the KIP. LGTM. I believe you can start a vote. -Matthias On 6/26/23 11:25 AM, Lucia Cerchie wrote: Thanks for asking for clarification, Sophie; that gives me guidance on improving the KIP! Here's the updated version, including the JIRA link:

Re: [DISCUSS] KIP-941 Support async runtimes in consumer

Seems the KIP number is 947, not 941? Can you maybe start a new thread to avoid confusion? Thanks. On 6/28/23 1:11 AM, Erik van Oosten wrote: Hello developers of the Java based consumer, I submitted https://github.com/apache/kafka/pull/13914 to fix a long standing problem that the Kafka

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #181

See Changes: -- [...truncated 423044 lines...] /home/jenkins/workspace/Kafka_kafka_3.3/streams/src/main/java/org/apache/kafka/streams/query/QueryResult.java:155: warning -

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

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

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.4 #148

See Changes: -- [...truncated 439125 lines...] [Pipeline] } [Pipeline] // dir [Pipeline] } [Pipeline] // withEnv [Pipeline] } [Pipeline] // withEnv [Pipeline] } [Pipeline] //

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #180

See Changes: -- [...truncated 337595 lines...] Running in /home/jenkins/workspace/Kafka_kafka_3.3/streams/quickstart [Pipeline] { [Pipeline] sh + mvn clean install -Dgpg.skip

Re: Requesting permissions to contribute to Apache Kafka

You should be all set. -- Divij Vaidya On Thu, Jun 29, 2023 at 8:45 PM Mayank Shekhar Narula < mayanks.nar...@gmail.com> wrote: > - can someone grant these? Thanks! > > As requested here - > >

Requesting permissions to contribute to Apache Kafka

- can someone grant these? Thanks! As requested here - https://cwiki.apache.org/confluence/display/kafka/kafka+improvement+proposals#KafkaImprovementProposals-GettingStarted " Wiki Id - mayanks*.*narula Jira Id - mayanksnarula Notice that Jira Id doesn't have the ".", whereas Wiki id does

[jira] [Resolved] (KAFKA-15053) Regression for security.protocol validation starting from 3.3.0

[ https://issues.apache.org/jira/browse/KAFKA-15053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Divij Vaidya resolved KAFKA-15053. -- Reviewer: Divij Vaidya Resolution: Fixed > Regression for security.protocol validation

Re: Offsets: consumption and production in rollback

Hi, Rollback does result in gaps in the offsets that a read-committed consumer sees. Log compaction can also result in gaps in the offsets. I am not aware of any way to force the “cleanup” of transactions. Thanks, Andrew > On 29 Jun 2023, at 09:08, Henry GALVEZ wrote: > > Hi Andrew, > > Yes,

Re: Permission to contribute to Apache Kafka

Hi Gaurav, you should be all set up now! Thanks for your interest in Apache Kafka! Best, Bruno On 29.06.23 16:16, Gaurav Narula wrote: Hi, Can someone please have a look at this request. Please let me know if there's any further information required. Thanks, Gaurav On 2023/06/26 19:01:08

RE: Permission to contribute to Apache Kafka

Hi, Can someone please have a look at this request. Please let me know if there's any further information required. Thanks, Gaurav On 2023/06/26 19:01:08 ka...@gnarula.com wrote: > Hi, > > I'd like to request permissions to contribute to Apache Kafka. My account > details are as follows: >

Re: [DISCUSS] KIP-793: Sink Connectors: Support topic-mutating SMTs for async connectors (preCommit users)

Hi Yash, Thanks for your continued work on this tricky feature. I have no further comments or suggestions on the KIP and am ready to vote in favor of it. That said, I did want to quickly respond to this comment: > On a side note, this also means that the per sink record ack API that was

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

See Changes: -- [...truncated 582441 lines...] > Task :streams:javadocJar > Task :clients:javadoc

Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.4 #147

See

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.5 #27

See

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

See Changes: -- [...truncated 578876 lines...] [Pipeline] } [Pipeline] // dir [Pipeline] } [Pipeline] // dir [Pipeline] } [Pipeline] // withEnv [Pipeline] } [Pipeline] //

[jira] [Created] (KAFKA-15134) Enrich the prompt reason in CommitFailedException

hudeqi created KAFKA-15134: -- Summary: Enrich the prompt reason in CommitFailedException Key: KAFKA-15134 URL: https://issues.apache.org/jira/browse/KAFKA-15134 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-14498) flaky org.apache.kafka.tools.MetadataQuorumCommandTest

[ https://issues.apache.org/jira/browse/KAFKA-14498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Divij Vaidya resolved KAFKA-14498. -- Resolution: Fixed > flaky org.apache.kafka.tools.MetadataQuorumCommandTest >

RE: Offsets: consumption and production in rollback

Hi Andrew, Yes, I have been using the requireStable option in the consumer group, but I consistently encounter the same issue. If I understand Kafka's logic correctly, it is essential for Kafka to retain those offsets even in the case of rollbacks. This is why relying on offsets within the

[jira] [Reopened] (KAFKA-14498) flaky org.apache.kafka.tools.MetadataQuorumCommandTest

[ https://issues.apache.org/jira/browse/KAFKA-14498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Divij Vaidya reopened KAFKA-14498: -- Assignee: (was: Luke Chen) > flaky org.apache.kafka.tools.MetadataQuorumCommandTest >

Re: [DISCUSS] Apache Kafka 3.5.1 release

SGTM, thanks Divij On Thu, 29 Jun 2023 at 03:16, Luke Chen wrote: > Hi Divij, > > Thanks for volunteering! > > Luke > > On Wed, Jun 28, 2023 at 11:54 PM Manyanda Chitimbo < > manyanda.chiti...@gmail.com> wrote: > > > Thank you Divij for volunteering to perform the release. > > > > On Wed 28 Jun