Kafka

I had an idea for a Kafka Streams implementation of Allen’s Temporal Logic (from the early 80’s), and came up with this. It’s just a toy/demo but I thought it was pretty cool what the AI (with significant help from me) could come up with in a few hours of effort. Article is here: https://www.linkedin.com/pulse/kafka-streams-implementation-allens-temporal-logic-llms-paul-brebner-j247e/ Code is here: https://github.com/paul-brebner/kafka-streams-allen-intervals/tree/main Enjoy! -- Regards, Paul Brebner NetApp Instaclustr Technology Evangelist Read my blogs at https://www.instaclustr.com/paul-brebner/ Follow me on https://www.linkedin.com/in/paul-brebner-0a547b4/

Hello Kafka users, developers and client-developers, This is the 3rd candidate for release of Apache Kafka 4.3.0. Since RC2, we've added fixes for: - https://issues.apache.org/jira/browse/KAFKA-20380 - https://issues.apache.org/jira/browse/KAFKA-20571 - https://issues.apache.org/jira/browse/KAFKA-20572 Release notes for the 4.3.0 release: https://dist.apache.org/repos/dist/dev/kafka/4.3.0-rc2/RELEASE_NOTES.html *** Please download, test and vote by May 20, 5pm CEST Kafka's KEYS file containing PGP keys we use to sign the release: https://downloads.apache.org/kafka/KEYS * Release artifacts to be voted upon (source and binary): https://dist.apache.org/repos/dist/dev/kafka/4.3.0-rc2/ * Docker release artifacts to be voted upon: apache/kafka:4.3.0-rc2 apache/kafka-native:4.3.0-rc2 * Maven artifacts to be voted upon: https://repository.apache.org/content/groups/staging/org/apache/kafka/ * Javadoc: https://dist.apache.org/repos/dist/dev/kafka/4.3....

Hi, I did the following: - checked the signatures and checksums - built from source - ran the tests - Tested Docker Images: -- can start -- can create topics - ran quickstart - ran sample apps with consumer groups - checked Java client interaction from artifacts (admin, producer, consumer and streams) - checked Tiered Storage offloads to remote storage (with Aiven's plugin) - checked Kafka Connect Verified on Linux with JDK 21 +1 (binding) On Tue, May 12, 2026 at 5:31 PM Lucas Brutschy via dev <dev@kafka.apache.org> wrote: > +1 (non-binding) > > Verified on macOS arm64, JDK 17: > > * GPG signatures and SHA512 checksums for source, binary, and > site-docs tarballs > * LICENSE/NOTICE present > * Built source with ./gradlew jar — BUILD SUCCESSFUL > * git tag 4.2.1-rc4 commit matches the shipped jar's > kafka-version.properties commitId > * KRaft quickstart: format --standalone, broker start, > t...

+1 (non-binding) Verified on macOS arm64, JDK 17: * GPG signatures and SHA512 checksums for source, binary, and site-docs tarballs * LICENSE/NOTICE present * Built source with ./gradlew jar — BUILD SUCCESSFUL * git tag 4.2.1-rc4 commit matches the shipped jar's kafka-version.properties commitId * KRaft quickstart: format --standalone, broker start, topic/produce/consume * KIP-1071 streams group: ran WordCountDemo with group.protocol=streams; logs show StreamsGroupHeartbeatRequestManager and counts aggregate correctly across rounds. Exercised kafka-streams-groups.sh --list/--describe/--members/--state/--offsets/ --verbose; --reset-offsets correctly rejected while Stable, accepted once Empty * Docker images apache/kafka and apache/kafka-native: both start, produce/consume works against each, commitId matches the tag * Documentation, javadoc, protocol, release-notes, and GitHub tag URLs all reachable * Maven staging artifacts present with La...

Hi Mickael, I did the following: - verified the checksums and signatures - build from source (java 21) -> run quickstart, basic produce/consume with Classic and Consumer groups - run basic consume/produce on both docker images - run the network degrade sys test that was failing on your side. I got a green run for the test_rate on 4.3 after some retries https://confluent-open-source-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/trunk/2026-05-11--001.f3134388-b3df-48e5-ae8b-98d07ddfff55--1778526564--apache--4.3--84b51283d6/report.html +1 (binding) Best! Lianet On Mon, May 11, 2026 at 2:51 PM Jakub Scholz <jakub@scholz.cz> wrote: > @Maciej: You mean within Strimzi? The system tests we have covering OAuth > passed. But I have not done any special testing for that as OAuth is not > really my specialty. > > Jakub > > On Mon, May 11, 2026 at 5:36 PM Maciej Malecki <emaciejm@gmail.com> wrote: > > ...

@Maciej: You mean within Strimzi? The system tests we have covering OAuth passed. But I have not done any special testing for that as OAuth is not really my specialty. Jakub On Mon, May 11, 2026 at 5:36 PM Maciej Malecki <emaciejm@gmail.com> wrote: > Does this version work with strimzi oauth 0.17.1? > > *__________________* > *Regards,* > > *Maciej Małecki* > > pon., 11 maj 2026, 16:58 użytkownik Jakub Scholz <jakub@scholz.cz> > napisał: > > > I used the staged binaries and Maven artifacts, and: > > * did some manual smoke testing > > * Run it within Strimzi and its system tests > > > > All seems to work fine, so +1 (non-binding). > > > > Thanks & Regards > > Jakub > > > > On Tue, May 5, 2026 at 1:41 PM Mickael Maison <mickael.maison@gmail.com> > > wrote: > > > > > Hello Kafka users, developers and client-developers, >...

Does this version work with strimzi oauth 0.17.1? *__________________* *Regards,* *Maciej Małecki* pon., 11 maj 2026, 16:58 użytkownik Jakub Scholz <jakub@scholz.cz> napisał: > I used the staged binaries and Maven artifacts, and: > * did some manual smoke testing > * Run it within Strimzi and its system tests > > All seems to work fine, so +1 (non-binding). > > Thanks & Regards > Jakub > > On Tue, May 5, 2026 at 1:41 PM Mickael Maison <mickael.maison@gmail.com> > wrote: > > > Hello Kafka users, developers and client-developers, > > > > This is the 2nd candidate for release of Apache Kafka 4.3.0. > > > > This release includes 25 KIPs bringing improvements to all components. > > > > Release notes for the 4.3.0 release: > > > https://dist.apache.org/repos/dist/dev/kafka/4.3.0-rc1/RELEASE_NOTES.html > > > > *** Please download, test and vote ...