Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #425

See Changes: [github] KAFKA-12194: use stateListener to catch each state change (#9888) -- [...truncated 3.57 MB...] TopologyTestDriverEosTest > shouldPass

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #406

See Changes: [github] KAFKA-12194: use stateListener to catch each state change (#9888) -- [...truncated 3.57 MB...] OutputVerifierTest > shouldNotAllowNull

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #377

See Changes: [github] KAFKA-12194: use stateListener to catch each state change (#9888) -- [...truncated 3.55 MB...] MockProcessorContextStateStoreTest > bui

[jira] [Resolved] (KAFKA-12195) Fix synchronization issue happening in KafkaStreams (related to flaky AdjustStreamThreadCountTest)

[ https://issues.apache.org/jira/browse/KAFKA-12195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12195. Fix Version/s: 2.8.0 Resolution: Fixed > Fix synchronization issue happening in Kaf

[jira] [Created] (KAFKA-12224) Api Request DescribeUserScramCredentials

Ronald Lampard created KAFKA-12224: -- Summary: Api Request DescribeUserScramCredentials Key: KAFKA-12224 URL: https://issues.apache.org/jira/browse/KAFKA-12224 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-12225) Unexpected broker bottleneck when scaling producers

Harel Ben Attia created KAFKA-12225: --- Summary: Unexpected broker bottleneck when scaling producers Key: KAFKA-12225 URL: https://issues.apache.org/jira/browse/KAFKA-12225 Project: Kafka Iss

Re: [DISCUSS] KIP-697: Stricter parsing of addresses in configs

Hi Gwen, Thanks for taking the time to look at it. 1. It's difficult to have a clear idea how often people supply a protocol. I wouldn't expect it to be common, since the documentation doesn't mention it. Maybe early users of Kafka still have the protocol in their configs (assuming it was documen

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #378

See Changes: [github] KAFKA-12195 Fix synchronization issue happening in KafkaStreams (#9887) -- [...truncated 3.55 MB...] MockProcessorContextStateStoreTest

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #407

See Changes: [github] KAFKA-12195 Fix synchronization issue happening in KafkaStreams (#9887) -- [...truncated 3.58 MB...] TestTopicsTest > testDuration() PA

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #426

See Changes: [github] KAFKA-12195 Fix synchronization issue happening in KafkaStreams (#9887) -- [...truncated 3.57 MB...] MockProcessorContextStateStoreTest

Re: [DISCUSS] KIP-705: Selectively Disable Topology Optimizations

I like that API! I'll wait a day or two to give people the opportunity to chime in and then update the wiki. Thanks for the feedback, Almog On Mon, Jan 18, 2021 at 10:00 PM Guozhang Wang wrote: > Thanks for the KIP Almog! > > I am in favor of the motivation of this proposal, and just throwing o

JUnit 4 to JUnit 5 conversion

Hi all, A heads up that most modules have been converted from JUnit 4 to JUnit 5. See KAFKA-7339[1] for more details. The following guides are useful if you want to learn more about JUnit 5 or how a given JUnit 4 feature works in JUnit 5: * https://junit.org/junit5/docs/current/user-guide/#migrat

Requesting review of a long pending Kafka Connect balanced task distribution PR

Hi Team, This is a major fix required to use consumer incremental co operative rebalance in kafka connect. Please help in reviewing the PR. https://github.com/apache/kafka/pull/9319 Thanks, Ramesh

Need permission to create a KIP

Hi, Can someone give me permission to create a KIP? My Apache Id is hcai ( h...@pinterest.com) https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals Thanks.

We want to remove Zookeeper from our Kafka cluster which version to use?

Hi All, We have a Kafka cluster [5-10 nodes] with multiple topics [with multi partitions] managed by the Zookeeper cluster. We want to remove the Zookeeper and manage the metadata using Kafka itself. I have gone through KIP 500 [Kafka] but nowhere it is mentioned which version of Kafka will thi

[jira] [Resolved] (KAFKA-12204) Implement DescribeCluster API on the broker

[ https://issues.apache.org/jira/browse/KAFKA-12204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-12204. - Fix Version/s: 2.8.0 Resolution: Fixed > Implement DescribeCluster API on the broker > --

Re: [DISCUSS] KIP-691: Transactional Producer Exception Handling

Thanks for the input Guozhang, replied inline. On Mon, Jan 18, 2021 at 8:57 PM Guozhang Wang wrote: > Hello Boyang, > > Thanks for the updated KIP. I read it again and have the following > thoughts: > > 0. I'm a bit concerned that if commitTxn does not throw any non-fatal > exception, and instea

[jira] [Resolved] (KAFKA-12219) Potential race condition in InMemoryKeyValueStore

[ https://issues.apache.org/jira/browse/KAFKA-12219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-12219. --- Fix Version/s: 2.8.0 Resolution: Fixed > Potential race condition in InMemoryKeyValue

Re: Need permission to create a KIP

Hello Henry, You should be able to create KIP now. Thanks! Guozhang On Tue, Jan 19, 2021 at 8:45 AM Henry Cai wrote: > Hi, > > Can someone give me permission to create a KIP? My Apache Id is hcai ( > h...@pinterest.com) > > > https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #408

See Changes: [github] MINOR: Ensure compile and runtime classpaths have consistent versions (#9921) [github] MINOR: Exclude junit 3 transitive dependency from jfreechart (#9928) -

Re: [DISCUSS] KIP-691: Transactional Producer Exception Handling

Thanks for your clarification on 2)/3), that makes sense. On Tue, Jan 19, 2021 at 10:16 AM Boyang Chen wrote: > Thanks for the input Guozhang, replied inline. > > On Mon, Jan 18, 2021 at 8:57 PM Guozhang Wang wrote: > > > Hello Boyang, > > > > Thanks for the updated KIP. I read it again and hav

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #427

See Changes: [github] MINOR: Ensure compile and runtime classpaths have consistent versions (#9921) [github] MINOR: Exclude junit 3 transitive dependency from jfreechart (#9928) [github] MINOR: Re

[jira] [Created] (KAFKA-12226) High-throughput source tasks fail to commit offsets

Chris Egerton created KAFKA-12226: - Summary: High-throughput source tasks fail to commit offsets Key: KAFKA-12226 URL: https://issues.apache.org/jira/browse/KAFKA-12226 Project: Kafka Issue T

Re: We want to remove Zookeeper from our Kafka cluster which version to use?

Manor, If you check the KIP it’s not yet implemented. Also, I believe we might see some update on ASF Kafka site and/or Confluent soon about this. In other words, you cannot just use it yet. Last I remember, Collin was PMing KIP-500 - so I would let them comment on this. Regards, On Tue, 19 J

Jenkins build is back to normal : Kafka » kafka-trunk-jdk8 #379

See

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #428

See Changes: [github] KAFKA-12204; Implement DescribeCluster API in the broker (KIP-700) (#9903) [github] KAFKA-10017: fix uncaucht-exception handling in EosBetaUpgradeIntegrationTest (#9733) [gi

Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #96

See Changes: [A. Sophie Blee-Goldman] KAFKA-12219: Add 'synchronized' keyword to InMemoryKeyValueStore#[reverseRange, reverseAll] (#9923) -- [...truncated 3.44

Re: [VOTE] KIP-659: Improve TimeWindowedDeserializer and TimeWindowedSerde to handle window size

Hi all, I've just caught up on the thread, and FWIW, I'm still +1. Thanks, -John On Mon, 2021-01-18 at 21:53 -0800, Guozhang Wang wrote: > Read the above updates and the KIP's scope. Makes sense to me. +1 still > counts :) > > On Wed, Jan 13, 2021 at 2:04 PM Sophie Blee-Goldman > wrote: > > >

Build failed in Jenkins: Kafka » kafka-2.6-jdk8 #72

See Changes: [John Roesler] MINOR: Fix StreamsOptimizedTest (#9911) -- [...truncated 3.17 MB...] org.apache.kafka.streams.internals.WindowStoreFacadeTest > shou

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #409

See Changes: [github] MINOR: Replace ApiVersion by auto-generated protocol (#9746) [github] KAFKA-12204; Implement DescribeCluster API in the broker (KIP-700) (#9903) [github] KAFKA-10017: fix unc

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #380

See Changes: [github] MINOR: Replace ApiVersion by auto-generated protocol (#9746) [github] KAFKA-12204; Implement DescribeCluster API in the broker (KIP-700) (#9903) [github] KAFKA-10017: fix unca

Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #97

See Changes: [John Roesler] MINOR: Fix StreamsOptimizedTest (#9911) [A. Sophie Blee-Goldman] KAFKA-9924: Add docs for RocksDB properties-based metrics (#9895)

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #429

See Changes: [github] MINOR: Fix StreamsOptimizedTest (#9911) [github] KAFKA-9924: Add docs for RocksDB properties-based metrics (#9895) -- [...truncated 3.

Re: [DISCUSS] KIP-705: Selectively Disable Topology Optimizations

Thanks for the KIP Almog. Overall, I agree that the source-topic optimization for KTables can be tricky. However, I am not a big fan of changing the configs. It might be better to disable this optimization in the code on a per-table basis instead. For this case, one could rewrite the code: // so

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #410

See Changes: [github] MINOR: Fix StreamsOptimizedTest (#9911) [github] KAFKA-9924: Add docs for RocksDB properties-based metrics (#9895) -- [...truncated 3.

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #411

See Changes: [github] MINOR: Add 'task container' class to KafkaStreams TaskManager (#9835) -- [...truncated 3.58 MB...] TestTopicsTest > shouldNotAllowToCr

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #430

See Changes: [github] MINOR: Add 'task container' class to KafkaStreams TaskManager (#9835) -- [...truncated 3.57 MB...] MockProcessorContextStateStoreTest

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #381

See Changes: [github] MINOR: Add 'task container' class to KafkaStreams TaskManager (#9835) -- [...truncated 3.57 MB...] TopologyTestDriverEosTest > shouldPu

[jira] [Resolved] (KAFKA-8460) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[ https://issues.apache.org/jira/browse/KAFKA-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-8460. --- Fix Version/s: 2.8.0 Resolution: Fixed > Flaky Test PlaintextConsumerTest#testLowMaxF