[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

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 >

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-jdk11 #411

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

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

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: //

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

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-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

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

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 >

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.7-jdk8 #96

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

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)

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

See

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

[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

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: [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

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: 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) > > >

[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

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

[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 >

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

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

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: *

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

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...]

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()

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...]

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

[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

[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:

[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

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 >

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 >

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 >