[jira] [Reopened] (KAFKA-3246) Transient Failure in kafka.producer.SyncProducerTest.testProduceCorrectlyReceivesResponse

[ https://issues.apache.org/jira/browse/KAFKA-3246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-3246: Happend again: [https://builds.apache.org/blue/organizations/jenkins/kafka-1.1-jdk7/detail/kaf

[jira] [Created] (KAFKA-8022) Flaky Test RequestQuotaTest#testExemptRequestTime

Matthias J. Sax created KAFKA-8022: -- Summary: Flaky Test RequestQuotaTest#testExemptRequestTime Key: KAFKA-8022 URL: https://issues.apache.org/jira/browse/KAFKA-8022 Project: Kafka Issue Typ

[jira] [Resolved] (KAFKA-6904) DynamicBrokerReconfigurationTest#testAdvertisedListenerUpdate is flaky

[ https://issues.apache.org/jira/browse/KAFKA-6904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6904. Resolution: Duplicate > DynamicBrokerReconfigurationTest#testAdvertisedListenerUpdate is fl

[jira] [Resolved] (KAFKA-7541) Transient Failure: kafka.server.DynamicBrokerReconfigurationTest.testUncleanLeaderElectionEnable

[ https://issues.apache.org/jira/browse/KAFKA-7541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7541. Resolution: Duplicate Fix Version/s: (was: 2.2.1) (was: 2.

[jira] [Reopened] (KAFKA-7288) Transient failure in SslSelectorTest.testCloseConnectionInClosingState

[ https://issues.apache.org/jira/browse/KAFKA-7288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-7288: Seems not to be fixed: [https://builds.apache.org/blue/organizations/jenkins/kafka-trunk-jdk8/

Jenkins build is back to normal : kafka-2.0-jdk8 #233

See

Fwd: Apache Kafka Memory Leakage???

Thanks, -- Forwarded message - From: Syed Mudassir Ahmed Date: Tue, Feb 26, 2019 at 12:40 PM Subject: Apache Kafka Memory Leakage??? To: Cc: Syed Mudassir Ahmed Hi Team, I have a java application based out of latest Apache Kafka version 2.1.1. I have a consumer applicati

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

See Changes: [bill] KAFKA-8011: Fix for race condition causing concurrent modification -- [...truncated 1.33 MB...] kafka.zookeeper.ZooKeeperClientTest > testSetAclNonExiste

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

See

[jira] [Created] (KAFKA-8021) KafkaProducer.flush() can show unexpected behavior when a batch is split

Abhishek Mendhekar created KAFKA-8021: - Summary: KafkaProducer.flush() can show unexpected behavior when a batch is split Key: KAFKA-8021 URL: https://issues.apache.org/jira/browse/KAFKA-8021 Proj

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

See Changes: [jason] KAFKA-8012; Ensure partitionStates have not been removed before [wangguoz] KAFKA-7918: Inline generic parameters Pt. III: in-memory window store -- [

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

See Changes: [matthias] MINOR: fix release.py script (#6317) [jason] HOTFIX: Change header back to http instead of https to path license [bill] KAFKA-8011: Fix for race condition causing concurrent modification --

Build failed in Jenkins: kafka-1.1-jdk7 #249

See Changes: [bill] Fixing merge conflicts from cherry pick -- [...truncated 1.94 MB...] org.apache.kafka.streams.StreamsConfigTest > shouldNotOverrideUserConfigRetriesIfEx

Build failed in Jenkins: kafka-1.0-jdk7 #263

See Changes: [bill] KAFKA-8011: Fix for race condition causing concurrent modification -- [...truncated 1.86 MB...] org.apache.kafka.streams.processor.internals.InternalTopo

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

See Changes: [jason] HOTFIX: Change header back to http instead of https to path license [jason] MINOR: Skip quota check when replica is in sync (#6344) [wangguoz] KAFKA-7912: Support concurrent access in InMem

[jira] [Created] (KAFKA-8020) Consider making ThreadCache a time-aware LRU Cache

Richard Yu created KAFKA-8020: - Summary: Consider making ThreadCache a time-aware LRU Cache Key: KAFKA-8020 URL: https://issues.apache.org/jira/browse/KAFKA-8020 Project: Kafka Issue Type: Improv

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

See Changes: [github] MINOR: fix release.py script (#6317) [jason] HOTFIX: Change header back to http instead of https to path license [jason] MINOR: Skip quota check when replica is in sync (#6344) [wangguoz]

Re: KIP-213 - Scalable/Usable Foreign-Key KTable joins - Rebooted.

Adam, I finally had the time to review the KIP and catch up on the mailing list discussion. Thanks a lot for putting this together! Great work! Of course also big thanks to Jan who started the KIP initially. This is a long email, because I re-read the discussion for multiple month and reply to ma

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

See Changes: [matthias] MINOR: state.cleanup.delay.ms default is 600,000 ms (10 minutes). -- [...truncated 2.62 MB...] kafka.api.SaslOAuthBearerSslEndToEndAuthorizationTest >

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

See Changes: [mjsax] MINOR: state.cleanup.delay.ms default is 600,000 ms (10 minutes). [jason] MINOR: Improve logging for alter log dirs (#6302) [github] MINOR: Remove types from caching stores (#6331) ---

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

See Changes: [mjsax] MINOR: state.cleanup.delay.ms default is 600,000 ms (10 minutes). [jason] MINOR: Improve logging for alter log dirs (#6302) [github] MINOR: Remove types from caching stores (#6331) [github

Re: [DISCUSS] KIP-427: Add AtMinIsr topic partition category (new metric & TopicCommand option)

Hey Kevin, Harsha, Thanks for the explanation! Now I agree with the motivation and the addition of this metric. Regards, Dong On Thu, Feb 28, 2019 at 12:30 PM Kevin Lu wrote: > Hi Harsha, thanks for the context. It's very useful to see how this > AtMinIsr metric will function under different e

Build failed in Jenkins: kafka-1.1-jdk7 #248

See Changes: [matthias] MINOR: disable Streams system test for broker upgrade/downgrade (#6341) [matthias] MINOR: state.cleanup.delay.ms default is 600,000 ms (10 minutes). ---

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

See Changes: [matthias] MINOR: state.cleanup.delay.ms default is 600,000 ms (10 minutes). -- [...truncated 1.92 MB...] org.apache.kafka.trogdor.coordinator.CoordinatorTest >

Re: [DISCUSS] KIP-427: Add AtMinIsr topic partition category (new metric & TopicCommand option)

Hi Harsha, thanks for the context. It's very useful to see how this AtMinIsr metric will function under different environments. Hi Dong, Thanks for the response. Let me try to change your mind. :) I think it's important to relate this metric with the different scenarios/configurations that peopl

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

See Changes: [mjsax] MINOR: disable Streams system test for broker upgrade/downgrade (#6341) -- [...truncated 4.62 MB...] org.apache.kafka.trogdor.coordinator.Coordinator

[DISCUSS] KIP-429 : Smooth Auto-Scaling for Kafka Streams

Hey community friends, I'm gladly inviting you to have a look at the proposal to add incremental rebalancing to Kafka Streams, A.K.A auto-scaling support. https://cwiki.apache.org/confluence/display/KAFKA/KIP-429%3A+Smooth+Auto-Scaling+for+Kafka+Streams Special thanks to Guozhang for giving gre

Re: [DISCUSSION] KIP-422: Add support for user/client configuration in the Kafka Admin Client

Hello folks, Please share your comments for this KIP 😄 Thanks! Yaodong On Tue, Feb 26, 2019 at 6:53 PM Yaodong Yang wrote: > Hello Colin, > > There is a POC PR for this KIP, and it contains most changes we are > proposing now. > > Best, > Yaodong > > On Tue, Feb 26, 2019 at 6:51 PM Yaodong Yan

Re: [DISCUSS] KIP-427: Add AtMinIsr topic partition category (new metric & TopicCommand option)

Hi Dong, I think AtMinIsr is still valuable to indicate cluster is at a critical state and something needs to be done asap to restore. To your example " let's say min_isr = 1 and replica_set_size = 3, it is > still possible that planned maintenance (e.g. one broker restart + > partit

Build failed in Jenkins: kafka-2.0-jdk8 #232

See Changes: [matthias] MINOR: disable Streams system test for broker upgrade/downgrade (#6341) [matthias] MINOR: state.cleanup.delay.ms default is 600,000 ms (10 minutes). ---

Re: Speeding up integration tests

Hey All, Thanks for the loads of ideas. @Stanislav, @Sonke I probably left it out from my email but I really imagined this as a case-by-case basis change. If we think that it wouldn't cause problems, then it might be applied. That way we'd limit the blast radius somewhat. The 1 hour gain is reall

[jira] [Created] (KAFKA-8019) Better Scaling Experience for KStream

Boyang Chen created KAFKA-8019: -- Summary: Better Scaling Experience for KStream Key: KAFKA-8019 URL: https://issues.apache.org/jira/browse/KAFKA-8019 Project: Kafka Issue Type: New Feature

[jira] [Created] (KAFKA-8018) Flaky Test SaslSslAdminClientIntegrationTest#testLegacyAclOpsNeverAffectOrReturnPrefixed

Matthias J. Sax created KAFKA-8018: -- Summary: Flaky Test SaslSslAdminClientIntegrationTest#testLegacyAclOpsNeverAffectOrReturnPrefixed Key: KAFKA-8018 URL: https://issues.apache.org/jira/browse/KAFKA-8018

[jira] [Resolved] (KAFKA-8016) Race condition resulting in IllegalStateException inside Consumer Heartbeat thread when consumer joins group

[ https://issues.apache.org/jira/browse/KAFKA-8016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski resolved KAFKA-8016. Resolution: Duplicate This is a symptom of https://issues.apache.org/jira/browse/KA

[jira] [Created] (KAFKA-8017) Narrow the scope of Streams' broker-upgrade-test

Guozhang Wang created KAFKA-8017: Summary: Narrow the scope of Streams' broker-upgrade-test Key: KAFKA-8017 URL: https://issues.apache.org/jira/browse/KAFKA-8017 Project: Kafka Issue Type: Im

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

See Changes: [vahid.hashemian] KAFKA-7962: Avoid NPE for StickyAssignor (#6308) -- [...truncated 3.94 MB...] kafka.api.GroupAuthorizerIntegrationTest > testAuthorizationW

[jira] [Created] (KAFKA-8016) Race condition resulting in IllegalStateException inside Consumer Heartbeat thread when consumer joins group

Stanislav Kozlovski created KAFKA-8016: -- Summary: Race condition resulting in IllegalStateException inside Consumer Heartbeat thread when consumer joins group Key: KAFKA-8016 URL: https://issues.apache.org/ji

[jira] [Resolved] (KAFKA-7940) Flaky Test CustomQuotaCallbackTest#testCustomQuotaCallback

[ https://issues.apache.org/jira/browse/KAFKA-7940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski resolved KAFKA-7940. Resolution: Fixed Reviewer: Rajini Sivaram Fixed with https://github.com/apac

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

See

Re: [VOTE] 2.2.0 RC0 [CANCELED]

We discovered a blocker issue: https://issues.apache.org/jira/browse/KAFKA-8012 Thus, I am cancelling the current vote. I will cut a new RC after the blocker is fixed. Nevertheless, please keep testing. If we find something else before the new RC is cut, it would streamline the overall process.

[jira] [Created] (KAFKA-8015) Flaky Test SaslGssapiSslEndToEndAuthorizationTest#testProduceConsumeTopicAutoCreateTopicCreateAcl

Matthias J. Sax created KAFKA-8015: -- Summary: Flaky Test SaslGssapiSslEndToEndAuthorizationTest#testProduceConsumeTopicAutoCreateTopicCreateAcl Key: KAFKA-8015 URL: https://issues.apache.org/jira/browse/KAFKA-801