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

See Changes: [github] KAFKA-5876: Add new exception types for Interactive Queries (#8200) [manikumar.reddy] KAFKA-8264: decrease the record size for flaky test [github] MINOR: Publish metrics package in the

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

See Changes: [github] KAFKA-5876: Add new exception types for Interactive Queries (#8200) [manikumar.reddy] KAFKA-8264: decrease the record size for flaky test [github] MINOR: Publish metrics package in the

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

See Changes: [manikumar.reddy] KAFKA-8264: decrease the record size for flaky test [github] MINOR: Publish metrics package in the javadoc (#9036) -- [...truncated 6.41

[jira] [Resolved] (KAFKA-10268) dynamic config like "--delete-config log.retention.ms" doesn't work

[ https://issues.apache.org/jira/browse/KAFKA-10268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx resolved KAFKA-10268. Fix Version/s: 2.7.0 Resolution: Fixed > dynamic config like "--delete-config log.retention.ms"

Re: [DISCUSS] KIP-450: Sliding Windows

Thanks for the discussion about extending TimeWindows. I agree that making it future proof is important, and the implementation of SlidingWindows is unique enough that it seems logical to make it its own final class. On that note, I've updated the KIP to make SlidingWindows a stand alone final

[GitHub] [kafka-site] guozhangwang commented on pull request #269: Kafka nav and hompeage redesign

guozhangwang commented on pull request #269: URL: https://github.com/apache/kafka-site/pull/269#issuecomment-663299804 @scott-confluent if you could paste the outlooks as images when it's ready for final review and merge that would be greatly appreciated.

[jira] [Created] (KAFKA-10301) RemoteReplicasMap can be empty in certain race conditions

Stanislav Kozlovski created KAFKA-10301: --- Summary: RemoteReplicasMap can be empty in certain race conditions Key: KAFKA-10301 URL: https://issues.apache.org/jira/browse/KAFKA-10301 Project:

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

Thanks Bruno, they made sense to me. Regarding the last comment, my main reasoning is that it's better to explain to users the rocksDB memory usage and link the metrics to different categories. Just to kick off this (and also asking for correction of my own understanding :) here's what I read

[jira] [Created] (KAFKA-10302) Ensure thread-safe access to Partition#remoteReplicasMap

Stanislav Kozlovski created KAFKA-10302: --- Summary: Ensure thread-safe access to Partition#remoteReplicasMap Key: KAFKA-10302 URL: https://issues.apache.org/jira/browse/KAFKA-10302 Project: Kafka

Re: Confluent Platform- KTable clarification

The ides is "sum value by key" in this example, what is maybe not the perfect example. However, if you have a KTable, you can do a `groupBy(...).aggregate(...)` and the same update logic applies: k1 : a,1 k2 : a,2 k3 : b,3 k4 : b,4 If you groupBy the first attribute in the value and sum, you

[jira] [Created] (KAFKA-10303) kafka producer says connect failed in cluster mode

Yogesh BG created KAFKA-10303: - Summary: kafka producer says connect failed in cluster mode Key: KAFKA-10303 URL: https://issues.apache.org/jira/browse/KAFKA-10303 Project: Kafka Issue Type: Bug

Did not received reply for Kafka PR

I made a PR 3 months ago , approx. I even tagged a few of the other contributors ,but I haven't received any reply yet. Although I followed along with a contributing guide, I might have done something wrong while making a PR , since I was contributing for the first time , it was a learning

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

Hi Jun, Thank you for the comments! Ying, Harsha and I discussed and put our comments below. 1001. The KIP described a few scenarios of unclean leader elections. This is very useful, but I am wondering if this is the best approach. My understanding of the proposed approach is to allow the new

[jira] [Created] (KAFKA-10304) Revisit and improve the tests of MirrorMaker 2

Ning Zhang created KAFKA-10304: -- Summary: Revisit and improve the tests of MirrorMaker 2 Key: KAFKA-10304 URL: https://issues.apache.org/jira/browse/KAFKA-10304 Project: Kafka Issue Type: Test

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

Guozhang, Just to clarify, the "heap" for all these objects is actually the C++ heap, not the JVM heap. So in the words of a Java application these would all be considered "off-heap", right? (Of course there are some pointers in the Java heap to the off-heap objects but that size is trivial

[jira] [Resolved] (KAFKA-10300) fix flaky core/group_mode_transactions_test.py

[ https://issues.apache.org/jira/browse/KAFKA-10300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-10300. - Fix Version/s: 2.7.0 Resolution: Fixed merged to trunk > fix flaky

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

Hi, Satish, Thanks for the reply. A few quick comments below. 1001. I was thinking that you could just use the tiered metadata to do the reconciliation. The tiered metadata contains offset ranges and epoch history. Those should be enough for reconciliation purposes. 1003.3 Having just a

Re: [DISCUSS] KIP-617: Allow Kafka Streams State Stores to be iterated backwards

Thanks Matthias. 1. PR looks good to me. 2. About adding default methods, I think for correctness and backward compatibility default methods should be added to avoid breaking potential clients. I have updated the KIP accordingly. Jorge. On Thu, Jul 23, 2020 at 5:19 AM Matthias J. Sax wrote:

[jira] [Created] (KAFKA-10305) Print usage when parsing fails for ConsumerPerformance

huxihx created KAFKA-10305: -- Summary: Print usage when parsing fails for ConsumerPerformance Key: KAFKA-10305 URL: https://issues.apache.org/jira/browse/KAFKA-10305 Project: Kafka Issue Type:

Re: [DISCUSS] 2.5.1 Bug Fix Release

Hello all, Sorry again for the delay. While completing the RC, I found and had to fix a broken system test. However, I've just created the vote thread for 2.5.1 RC0! Please take a look at it and let me know what you think. Thanks, -John On Tue, Jul 14, 2020, at 17:22, John Roesler wrote: >

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

See

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

See Changes: [github] KAFKA-10268: dynamic config like "--delete-config log.retention.ms" -- [...truncated 3.20 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

[VOTE] 2.5.1 RC0

Hello Kafka users, developers and client-developers, This is the first candidate for release of Apache Kafka 2.5.1. Apache Kafka 2.5.1 is a bugfix release and fixes 72 issues since the 2.5.0 release. Please see the release notes for more information. Release notes for the 2.5.1 release:

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

See Changes: [github] KAFKA-10300 fix flaky core/group_mode_transactions_test.py (#9059) -- [...truncated 6.41 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

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

See