Re: [VOTE] KIP-415: Incremental Cooperative Rebalancing in Kafka Connect

Nice work Konstantine! +1 (non-binding) On Fri, Mar 15, 2019 at 7:48 AM Ewen Cheslack-Postava wrote: > +1 (binding) > > -Ewen > > On Wed, Mar 13, 2019 at 2:04 PM Randall Hauch wrote: > > > Excellent work, Konstantine! > > > > +1 (binding) > > > > On Mon, Mar 11, 2019 at 8:05 PM Konstantine Kara

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

See Changes: [wangguoz] KAFKA-7502: Cleanup KTable materialization logic in a single place -- [...truncated 2.36 MB...] org.apache.kafka.trogdor.coordinator.CoordinatorTe

Re: [VOTE] KIP-415: Incremental Cooperative Rebalancing in Kafka Connect

+1 (binding) -Ewen On Wed, Mar 13, 2019 at 2:04 PM Randall Hauch wrote: > Excellent work, Konstantine! > > +1 (binding) > > On Mon, Mar 11, 2019 at 8:05 PM Konstantine Karantasis < > konstant...@confluent.io> wrote: > > > Thanks Jason! > > That makes perfect sense. The change is reflected in th

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

See Changes: [rajinisivaram] KAFKA-8091; Remove unsafe produce from dynamic listener update test -- [...truncated 1.65 MB...] org.apache.kafka.streams.state.internals.RocksD

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

See

[jira] [Created] (KAFKA-8108) Flaky Test kafka.api.ClientIdQuotaTest.testThrottledProducerConsumer

Guozhang Wang created KAFKA-8108: Summary: Flaky Test kafka.api.ClientIdQuotaTest.testThrottledProducerConsumer Key: KAFKA-8108 URL: https://issues.apache.org/jira/browse/KAFKA-8108 Project: Kafka

[jira] [Created] (KAFKA-8107) Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete

Guozhang Wang created KAFKA-8107: Summary: Flaky Test kafka.api.ClientIdQuotaTest.testQuotaOverrideDelete Key: KAFKA-8107 URL: https://issues.apache.org/jira/browse/KAFKA-8107 Project: Kafka

[jira] [Resolved] (KAFKA-7730) Limit total number of active connections in the broker

[ https://issues.apache.org/jira/browse/KAFKA-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-7730. - Resolution: Fixed Reviewer: Gwen Shapira Fix Version/s: 2.3.0 > Limit total numbe

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

See Changes: [github] KAFKA-8091; Remove unsafe produce from dynamic listener update test -- [...truncated 2.35 MB...] org.apache.kafka.connect.converters.ByteArrayConver

Re: [DISCUSS] KIP-434: Add Replica Fetcher and Log Cleaner Count Metrics

Hey Stanislav, Sorry for the delay on this. In the meantime I realized that the dead fetchers won't be removed from the fetcher map, so it's very easy to figure out how many dead and alive there are. I can collect them on broker level which I think gives a good enough information if there is a pro

[jira] [Created] (KAFKA-8106) Unnecessary decompression operation in logValidator affect throughput.

Flower.min created KAFKA-8106: - Summary: Unnecessary decompression operation in logValidator affect throughput. Key: KAFKA-8106 URL: https://issues.apache.org/jira/browse/KAFKA-8106 Project: Kafka

Re: [DISCUSSION] KIP-421: Support resolving externalized secrets in AbstractConfig

Hi Tejal, Thanks for the update. One of the critical parts of the ConfigProvider interface is the ability to monitor changes to a configuration key through ConfigProvider#subscribe and ConfigProvider#unsubscribe, etc. I don't see how the proposed API supports this. Can you clarify? Also, it

Re: [DISCUSS] KIP-437: Custom replacement for MaskField SMT

Dear community members, I would be very grateful if you leave any feedback on this KIP. It will help me to understand if change is useful or not and to decide on further actions. Thank you in advance, Valeria пн, 11 мар. 2019 г. в 13:20, Valeria Vasylieva : > Hi All, > > I would like to start a

Re: [DISCUSSION] KIP-421: Support resolving externalized secrets in AbstractConfig

Hi Tejal, Thanks for the updates. A few comments: 1. In the standard KIP template, we have two sections `Public Interfaces` and `Proposed Changes`. Can you split the section `Proposal` into two so that public interface changes are more obvious? 2. Under `Public Interfaces`, can you s

[jira] [Created] (KAFKA-8105) Release notes page for 1.1.0 not working

Milen Hristov created KAFKA-8105: Summary: Release notes page for 1.1.0 not working Key: KAFKA-8105 URL: https://issues.apache.org/jira/browse/KAFKA-8105 Project: Kafka Issue Type: Bug