Build failed in Jenkins: kafka-2.6-jdk8 #92

See Changes: -- [...truncated 6.30 MB...] org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldCreateNullKeyConsumerRecord STARTED org.apache.kafka.streams.test.ConsumerRecord

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

See Changes: [github] KAFKA-10189: reset event queue time histogram when queue is empty -- [...truncated 3.17 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

Build failed in Jenkins: kafka-trunk-jdk14 #304

See Changes: [github] KAFKA-10189: reset event queue time histogram when queue is empty -- [...truncated 3.19 MB...] org.apache.kafka.streams.scala.kstream.StreamJoinedT

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

See

[GitHub] [kafka-site] vvcephei merged pull request #275: MINOR: update Streams docs for 2.6 and fix configs

vvcephei merged pull request #275: URL: https://github.com/apache/kafka-site/pull/275 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 t

Re: [VOTE] 2.6.0 RC0

Thanks, Rajini. I've cut RC1, but after I pushed the commit I found a discrepancy in the JavaDoc that mentions 2.7. Please see the "[VOTE] 2.6.0 RC1" discussion thread for details. On Mon, Jul 20, 2020 at 4:59 AM Rajini Sivaram wrote: > Thanks Randall. We didn't create a JIRA for the KIP-546 sec

[VOTE] 2.6.0 RC1

Hello Kafka users, developers and client-developers, This is the second candidate for release of Apache Kafka 2.6.0. This is a major release that includes many new features, including: * TLSv1.3 has been enabled by default for Java 11 or newer. * Smooth scaling out of Kafka Streams applications *

Re: [VOTE] 2.6.0 RC0

All, I've pushed a new release candidate (RC1) and announced via the "[VOTE] 2.6.0 RC1" discussion thread. Randall On Mon, Jul 20, 2020 at 9:51 PM Randall Hauch wrote: > Thanks, Rajini. I've cut RC1, but after I pushed the commit I found a > discrepancy in the JavaDoc that mentions 2.7. Please

Re: [VOTE] 2.6.0 RC1

When I was checking the documentation for RC1 after the tag was pushed, I noticed that the fix Rajini mentioned in the RC0 vote thread ( https://github.com/apache/kafka/pull/8979 ) and merged to the `2.6`

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

See

Re: [DISCUSS] KIP-405: Kafka Tiered Storage

Hi, Satish, Ying, Harsha, Thanks for the updated KIP. A few more comments below. 1000. Regarding Colin's question on querying the metadata directly in the remote block store. One issue is that not all block stores offer the needed api to query the metadata. For example, S3 only offers an api to l

Re: [DISCUSS] KIP-450: Sliding Windows

Hi Leah, Thanks for the updated KIP. I agree that extending SlidingWindows from Windows is fine for the sake of not introducing more public APIs (and their internal xxxImpl classes), and its cons is small enough to tolerate to me. Guozhang On Mon, Jul 20, 2020 at 1:49 PM Leah Thomas wrote: >

[GitHub] [kafka-site] ableegoldman commented on a change in pull request #275: MINOR: update Streams docs for 2.6 and fix configs

ableegoldman commented on a change in pull request #275: URL: https://github.com/apache/kafka-site/pull/275#discussion_r457761691 ## File path: 26/streams/upgrade-guide.html ## @@ -95,7 +95,19 @@ Streams API Note that you need brokers with version 2.5 or newer to use t

Build failed in Jenkins: kafka-trunk-jdk14 #303

See Changes: [github] KAFKA-9161: add docs for KIP-441 and KIP-613 and other configs that need -- [...truncated 3.20 MB...] org.apache.kafka.streams.test.OutputVerifier

Re: [DISCUSS] KIP-607: Add Metrics to Record the Memory Used by RocksDB to Kafka Streams

Hello Bruno, Thanks for the updated KIP. I made a pass and here are some comments: 1) What's the motivation of keeping it as INFO while KIP-471 metrics are defined in DEBUG? 2) Some namings are a bit inconsistent with others and with KIP-471, for example: 2.a) KIP-471 uses "memtable" while in t

Re: [VOTE] KIP-572: Improve timeouts and retires in Kafka Streams

While working on the PR, we realized that the command line tool bin/kafka-console-producer.sh has a flag `--message-send-max-retries` to set the producer's `retries` config. We also need to deprecate this flag. I updated the KIP accordingly. Please let us know if there are any concerns to this

[jira] [Created] (KAFKA-10297) Don't use deprecated producer config `retries`

Matthias J. Sax created KAFKA-10297: --- Summary: Don't use deprecated producer config `retries` Key: KAFKA-10297 URL: https://issues.apache.org/jira/browse/KAFKA-10297 Project: Kafka Issue Ty

[jira] [Resolved] (KAFKA-10253) Kafka Connect gets into an infinite rebalance loop

[ https://issues.apache.org/jira/browse/KAFKA-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Lalafaryan resolved KAFKA-10253. --- Resolution: Not A Problem Seems like we have found a problem, and it is rela

Re: [DISCUSS] KIP-450: Sliding Windows

Hi all, Thanks for the feedback on the KIP. I've updated the KIP page to address these points and have created a child page

Re: [DISCUSS] Kafka 3.0

Did we reach any conclusion on the subject? It seems we are aiming for 2.7 after 2.6 and plan the major version bump to 3.0 after 2.7 (assuming we make progress on ZK removal as planned?) -Matthias On 5/18/20 1:11 PM, Boyang Chen wrote: > One more thing I would like to see deprecated (hopefull

Jenkins build is back to normal : kafka-2.3-jdk8 #219

See

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

See Changes: [github] KAFKA-10286: Connect system tests should wait for workers to join group [github] KAFKA-10295: Wait for connector recovery in test_bounce (#9043) -

Build failed in Jenkins: kafka-trunk-jdk14 #302

See Changes: [github] KAFKA-10286: Connect system tests should wait for workers to join group [github] KAFKA-10295: Wait for connector recovery in test_bounce (#9043) --

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

See Changes: [github] KAFKA-10286: Connect system tests should wait for workers to join group [github] KAFKA-10295: Wait for connector recovery in test_bounce (#9043) --

Build failed in Jenkins: kafka-2.4-jdk8 #234

See Changes: [rhauch] KAFKA-10286: Connect system tests should wait for workers to join group [rhauch] KAFKA-10295: Wait for connector recovery in test_bounce (#9043) -- [.

Re: [DISCUSS] KIP-607: Add Metrics to Record the Memory Used by RocksDB to Kafka Streams

Hi, During the implementation of this KIP and after some discussion about RocksDB metrics, I decided to make some major modifications to this KIP and kick off discussion again. https://cwiki.apache.org/confluence/display/KAFKA/KIP-607%3A+Add+Metrics+to+Kafka+Streams+to+Report+Properties+of+Ro

Build failed in Jenkins: kafka-2.6-jdk8 #91

See Changes: [rhauch] KAFKA-10286: Connect system tests should wait for workers to join group [rhauch] KAFKA-10295: Wait for connector recovery in test_bounce (#9043) -- [..

Re: [DISCUSS] KIP-431: Support of printing additional ConsumerRecord fields in DefaultMessageFormatter

Thanks Badai. LGTM. On 7/19/20 4:26 PM, Badai Aqrandista wrote: > Hi all > > I have made a small change to KIP-431 to make it clearer which one is > "Partition" and "Offset". Also I have moved key field to the back, > before the value: > > $ kafka-console-consumer.sh --bootstrap-server localhost

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

See Changes: [manikumar.reddy] MINOR: Enable broker/client compatibility tests for 2.5.0 release -- [...truncated 3.20 MB...] org.apache.kafka.streams.test.OutputVerif

Build failed in Jenkins: kafka-2.6-jdk8 #90

See Changes: [manikumar.reddy] MINOR: Enable broker/client compatibility tests for 2.5.0 release -- [...truncated 3.15 MB...] org.apache.kafka.streams.test.OutputVerifierTe

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

See Changes: [manikumar.reddy] MINOR: Enable broker/client compatibility tests for 2.5.0 release -- [...truncated 3.17 MB...] org.apache.kafka.streams.test.OutputVerifie

Build failed in Jenkins: kafka-trunk-jdk14 #301

See Changes: [manikumar.reddy] MINOR: Enable broker/client compatibility tests for 2.5.0 release -- [...truncated 3.20 MB...] org.apache.kafka.streams.TopologyTestDrive

[jira] [Resolved] (KAFKA-10295) ConnectDistributedTest.test_bounce should wait for graceful stop

[ https://issues.apache.org/jira/browse/KAFKA-10295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-10295. --- Reviewer: Randall Hauch Resolution: Fixed > ConnectDistributedTest.test_bounce should

[jira] [Resolved] (KAFKA-10286) Connect system tests should wait for workers to join group

[ https://issues.apache.org/jira/browse/KAFKA-10286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-10286. --- Reviewer: Randall Hauch Resolution: Fixed > Connect system tests should wait for worke

Re: [VOTE] 2.6.0 RC0

Thanks Randall. We didn't create a JIRA for the KIP-546 security fix since KAFKA-7740 that introduced the regression had a fix version of 2.5.0. A fix was applied without a JIRA to follow the security bug fix process. In the end, it turned out that KAFKA-7740 was only in 2.6, so the bug hadn't got