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

2019-04-23 Thread Apache Jenkins Server
See Changes: [wangguoz] KAFKA-8204: fix Streams store flush order (#6555) (#6623) -- [...truncated 919.79 KB...] kafka.server.KafkaConfigTest > testFromPropsInvalid STARTED

Re: [DISCUSS] KIP-458: Connector Client Config Override Policy

2019-04-23 Thread Magesh Nandakumar
Hi all, I also have a draft implementation of the KIP https://github.com/apache/kafka/pull/6624. I would still need to include more tests and docs but I thought it would be useful to have this for the KIP discussion. Looking forward to all of your valuable feedback. Thanks Magesh On Tue, Apr 23,

Re: [DISCUSS] KIP-458: Connector Client Config Override Policy

2019-04-23 Thread Magesh Nandakumar
Chrise, Thanks a lot for your feedback. I will address them in order of your questions/comments. 1. Thanks for bringing this to my attention about KIP-382. I had a closer look at the KIP and IIUC, the KIP allows `consumer.` prefix for SourceConnector and producer. prefix for SinkConnector since t

Re: KIP-457: Add DISCONNECTED state to Kafka Streams

2019-04-23 Thread Richard Yu
Oh, so if possible. I thought it would be good if we could finish this KIP up. Matthias, or Michael, if you have any further comments, please let me know. :) Otherwise, I might restart the voting thread in a few days. Cheers, Richard On Wed, Apr 17, 2019 at 2:30 PM Richard Yu wrote: > Alright,

Re: Cannot create a KIP

2019-04-23 Thread Vahid Hashemian
Hi Daniyar, I gave KIP creation permission to user "daniyar.yeralin", assuming it's you :) Thanks for contributing! --Vahid On Tue, Apr 23, 2019 at 10:50 AM Daniyar Yeralin wrote: > Hello, > > I was trying to submit a PR: https://github.com/apache/kafka/pull/6592 > Matthias J. Sax told me that

Re: [VOTE] KIP-421: Automatically resolve external configurations.

2019-04-23 Thread Dongjin Lee
@Colin I see. Thanks for the correction! @Tejal Thanks for the excellent proposal! +1k! Thanks, Dongjin On Mon, Apr 22, 2019 at 10:26 PM Colin McCabe wrote: > Hi Dongjin, > > Thanks for checking out the KIP. > > Randall is a committer, actually. He was added two months ago. It looks > like he

[DISCUSS] KIP-459: Improve KafkaStreams#close

2019-04-23 Thread Dongjin Lee
Hi dev, I would like to start the discussion of KIP-459: Improve KafkaStreams#close . This proposal is originated from the issue reported via community slack, KAFKA-7996

Re: Requesting access to create KIPs

2019-04-23 Thread Bill Bejeck
Alex, you are all set now. -Bill On Tue, Apr 23, 2019 at 1:32 PM Alex Liu wrote: > Hello, > > I would like to have permissions to create content in this page: > > https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals > My wiki user is "alexliu". > > Thanks, > Alex >

Re: [DISCUSS] KIP-454: Expansion of the ConnectClusterState interface

2019-04-23 Thread Magesh Nandakumar
Chris, I certainly would love to hear others thoughts on #1 but IMO, it might not be as useful as ConnectorConfigs and as you mentioned, we could always add it when the need arises. Thanks for clarifying the details on my concern #2 regarding the kafkaClusterId. While not a perfect fit in the inte

Jenkins build is back to normal : kafka-2.1-jdk8 #170

2019-04-23 Thread Apache Jenkins Server
See

Re: [DISCUSS] KIP-454: Expansion of the ConnectClusterState interface

2019-04-23 Thread Chris Egerton
Hi Konstantine, I didn't fully grasp the rationale behind adding default implementations for the new interface at first; thanks for clarifying. I agree, this would be good to include. I've updated the KIP with proposed defaults for the new methods that simply throw UnsupportedOperationExceptions,

[jira] [Created] (KAFKA-8283) Add additional test cases for the topic deletion state machine

2019-04-23 Thread Jason Gustafson (JIRA)
Jason Gustafson created KAFKA-8283: -- Summary: Add additional test cases for the topic deletion state machine Key: KAFKA-8283 URL: https://issues.apache.org/jira/browse/KAFKA-8283 Project: Kafka

Requesting access to create KIPs

2019-04-23 Thread Alex Liu
Hello, I would like to have permissions to create content in this page: https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals My wiki user is "alexliu". Thanks, Alex

[jira] [Created] (KAFKA-8282) Missing JMX bandwidth quota metrics for Produce and Fetch

2019-04-23 Thread JMVM (JIRA)
JMVM created KAFKA-8282: --- Summary: Missing JMX bandwidth quota metrics for Produce and Fetch Key: KAFKA-8282 URL: https://issues.apache.org/jira/browse/KAFKA-8282 Project: Kafka Issue Type: Bug Aff

Cannot create a KIP

2019-04-23 Thread Daniyar Yeralin
Hello, I was trying to submit a PR: https://github.com/apache/kafka/pull/6592 Matthias J. Sax told me that I need to go through a formal process on https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals However, after creating an account, I do not have a permission to creat

Re: [DISCUSS] KIP-454: Expansion of the ConnectClusterState interface

2019-04-23 Thread Konstantine Karantasis
Thanks for the additions to the KIP Chris! The descriptions are quite clear now. With respect to 2) my main point was to say that you are targeting a version that assumes Java 8, so adding the additional methods as default is an option. I think it's good practice to do that, even if we think it's

[jira] [Created] (KAFKA-8281) Kstream hung and doing nothing

2019-04-23 Thread Nitin Patidar (JIRA)
Nitin Patidar created KAFKA-8281: Summary: Kstream hung and doing nothing Key: KAFKA-8281 URL: https://issues.apache.org/jira/browse/KAFKA-8281 Project: Kafka Issue Type: Bug Rep

[jira] [Created] (KAFKA-8280) Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable

2019-04-23 Thread John Roesler (JIRA)
John Roesler created KAFKA-8280: --- Summary: Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable Key: KAFKA-8280 URL: https://issues.apache.org/jira/browse/KAFKA-8280 Project: Kafk

[DISCUSS] KIP-456: Helper classes to make it simpler to write test logic with TopologyTestDriver

2019-04-23 Thread Jukka Karvanen
Hi All, I would like to start the discussion on KIP-456: Helper classes to make it simpler to write test logic with TopologyTestDriver: https://cwiki.apache.org/confluence/display/KAFKA/KIP-456%3A+Helper+classes+to+make+it+simpler+to+write+test+logic+with+TopologyTestDriver There is also relate

[jira] [Created] (KAFKA-8279) Discrepancy around what SubscriptionState.allConsumed returns

2019-04-23 Thread Kevin (JIRA)
Kevin created KAFKA-8279: Summary: Discrepancy around what SubscriptionState.allConsumed returns Key: KAFKA-8279 URL: https://issues.apache.org/jira/browse/KAFKA-8279 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-8278) MockConsumer.poll and MockConsumer.wakupe are both synchronized

2019-04-23 Thread Kevin (JIRA)
Kevin created KAFKA-8278: Summary: MockConsumer.poll and MockConsumer.wakupe are both synchronized Key: KAFKA-8278 URL: https://issues.apache.org/jira/browse/KAFKA-8278 Project: Kafka Issue Type: Bu

Jenkins build is back to normal : kafka-2.2-jdk8 #90

2019-04-23 Thread Apache Jenkins Server
See

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

2019-04-23 Thread Apache Jenkins Server
See

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

2019-04-23 Thread Apache Jenkins Server
See