Build failed in Jenkins: kafka-trunk-jdk11 #1347

See Changes: [github] KAFKA-3720: Change TimeoutException to BufferExhaustedException when no -- [...truncated 6.24 MB...] org.apache.kafka.streams.TopologyTestDriverTes

[DISCUSS] KIP-592: MirrorMaker should replicate topics from earliest

https://cwiki.apache.org/confluence/display/KAFKA/KIP-592%3A+MirrorMaker+should+replicate+topics+from+earliest It's a relatively minor change, only one line of code. :-D -- *Jeff Widman* jeffwidman.com | 740-WIDMAN-J (943-6265) <><

Jenkins build is back to normal : kafka-trunk-jdk11 #1346

See

Jenkins build is back to normal : kafka-trunk-jdk8 #4425

See

Re: [DISCUSS] KIP-588: Allow producers to recover gracefully from transaction timeouts

Thanks Boyang, the newly added example looks good to me. On Thu, Apr 9, 2020 at 2:47 PM Boyang Chen wrote: > Hey Guozhang, > > I have added an example of the producer API usage under new improvements. > Let me know if this looks good to you. > > Boyang > > On Wed, Apr 8, 2020 at 1:38 PM Boyang C

[jira] [Created] (KAFKA-9852) Lower block duration in BufferPoolTest to cut down on overall test runtime

Sönke Liebau created KAFKA-9852: --- Summary: Lower block duration in BufferPoolTest to cut down on overall test runtime Key: KAFKA-9852 URL: https://issues.apache.org/jira/browse/KAFKA-9852 Project: Kafka

Re: [DISCUSS] KIP-584: Versioning scheme for features

Hi, Kowshik, Thanks for the reply. A few more comments. 110. Keeping the feature version as int is probably fine. I just felt that for some of the common user interactions, it's more convenient to relate that to a release version. For example, if a user wants to downgrade to a release 2.5, it's e

Re: [kafka-clients] Re: [VOTE] 2.5.0 RC3

+1 (non-binding) Used the following environment in my validation of the release artifacts: Ubuntu 18.04, OpenJDK 11, Scala 2.13.1, Gradle 5.6.2 Verified GPG Signatures for all release artifacts Verified md5 sha1 sha512 checksums for each artifact Checked Scala and Java Docs Ran Unit and Integrati

Re: Want to be Part of Kafka Committer - Siva

Thank you. On Fri, Apr 10, 2020 at 2:37 PM Matthias J. Sax wrote: > Added you. > > > On 4/10/20 12:45 PM, siva deva wrote: > > Sure. > > > > This is my Username is SivagurunathanV. Please let me know if this works. > > > > Thanks, > > Siva > > > > On Fri, Apr 10, 2020 at 12:31 PM Matthias J. Sax

Build failed in Jenkins: kafka-trunk-jdk11 #1345

See Changes: [github] KAFKA-6145: KIP-441: avoid unnecessary movement of standbys (#8436) [github] KAFKA-9832: Extend Streams system tests for EOS-beta (#8443) -- [...t

Re: Want to be Part of Kafka Committer - Siva

Added you. On 4/10/20 12:45 PM, siva deva wrote: > Sure. > > This is my Username is SivagurunathanV. Please let me know if this works. > > Thanks, > Siva > > On Fri, Apr 10, 2020 at 12:31 PM Matthias J. Sax wrote: > >> Siva, >> >> I could not fine you in the system. Is the user-id you provid

Build failed in Jenkins: kafka-trunk-jdk8 #4424

See Changes: [github] KAFKA-6145: KIP-441: avoid unnecessary movement of standbys (#8436) [github] KAFKA-9832: Extend Streams system tests for EOS-beta (#8443) -- [...tr

Re: Want to be Part of Kafka Committer - Siva

Sure. This is my Username is SivagurunathanV. Please let me know if this works. Thanks, Siva On Fri, Apr 10, 2020 at 12:31 PM Matthias J. Sax wrote: > Siva, > > I could not fine you in the system. Is the user-id you provided > something internal? If yes, I would need the "user name" instead, i

Re: Want to be Part of Kafka Committer - Siva

Siva, I could not fine you in the system. Is the user-id you provided something internal? If yes, I would need the "user name" instead, ie, whatever you use to log in. Sorry for the confusion. -Matthias On 4/9/20 10:25 PM, siva deva wrote: > Hi > > Can someone add me to the contributor's list

Re: 回复：回复：回复：回复：回复：回复：[Vote] KIP-571: Add option to force remove members in StreamsResetter

Thanks Feyman, I've looked at the update that you incorporated from Matthias and that LGTM too. I'm still +1 :) Guozhang On Fri, Apr 10, 2020 at 11:18 AM John Roesler wrote: > Hey Feyman, > > Just to remove any ambiguity, I've been casually following the discussion, > I've just looked at the K

Re: 回复：回复：回复：回复：回复：回复：[Vote] KIP-571: Add option to force remove members in StreamsResetter

Hey Feyman, Just to remove any ambiguity, I've been casually following the discussion, I've just looked at the KIP document again, and I'm still +1 (binding). Thanks, -John On Fri, Apr 10, 2020, at 01:44, feyman2009 wrote: > Hi, all > KIP-571 has already collected 4 bind +1 (John, Guochang,

Re: [kafka-clients] Re: [VOTE] 2.5.0 RC3

Hi David, +1 (binding) - Verified signatures, artifacts, Release notes - Built from sources, ran tests - Ran core/streams quick start for Scala 2.13 binary, ran few manual tests - Verified docs As discussed offline, we need to add upgrade instructions to 2.5 docs. Thanks for driving the releas

[jira] [Created] (KAFKA-9851) Revoking Connect tasks due to connectivity issues should also clear running assignment

Konstantine Karantasis created KAFKA-9851: - Summary: Revoking Connect tasks due to connectivity issues should also clear running assignment Key: KAFKA-9851 URL: https://issues.apache.org/jira/browse/KAFKA-

[jira] [Created] (KAFKA-9850) Move KStream#repartition operator validation during Topology build process

Levani Kokhreidze created KAFKA-9850: Summary: Move KStream#repartition operator validation during Topology build process Key: KAFKA-9850 URL: https://issues.apache.org/jira/browse/KAFKA-9850 Pro

[jira] [Resolved] (KAFKA-6910) Ability to specify a default state store type or factory

[ https://issues.apache.org/jira/browse/KAFKA-6910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6910. Resolution: Duplicate > Ability to specify a default state store type or factory >

Re: [kafka-clients] Re: [VOTE] 2.5.0 RC3

Hi David, +1 (non-binding) Verified signatures, built jars from source, ran unit and integration tests, all passed. Thanks for running the release. -Bill On Wed, Apr 8, 2020 at 10:10 AM David Arthur wrote: > Passing Jenkins build on 2.5 branch: > https://builds.apache.org/job/kafka-2.5-jdk8/9

Build failed in Jenkins: kafka-2.1-jdk8 #264

See Changes: [jason] KAFKA-9654; Update epoch in `ReplicaAlterLogDirsThread` after new [jason] KAFKA-9750; Fix race condition with log dir reassign completion (#8412) -- [.

Build failed in Jenkins: kafka-trunk-jdk11 #1344

See Changes: [github] MINOR: Fix JavaDocs markup (#8459) [github] MINOR: Only start log dir fetcher after LeaderAndIsr epoch validation -- [...truncated 3.03 MB...] org

Build failed in Jenkins: kafka-2.2-jdk8 #44

See Changes: [jason] KAFKA-9654; Update epoch in `ReplicaAlterLogDirsThread` after new [jason] KAFKA-9750; Fix race condition with log dir reassign completion (#8412) -- [..

Jenkins build is back to normal : kafka-trunk-jdk8 #4422

See