[jira] [Created] (KAFKA-8392) Kafka broker leaks metric when partition leader moves to another node.

2019-05-19 Thread Kamal Chandraprakash (JIRA)
Kamal Chandraprakash created KAFKA-8392: --- Summary: Kafka broker leaks metric when partition leader moves to another node. Key: KAFKA-8392 URL: https://issues.apache.org/jira/browse/KAFKA-8392 Pr

Re: [VOTE] KIP-440: Extend Connect Converter to support headers

2019-05-19 Thread Kamal Chandraprakash
+1 (non-binding). Thanks for the KIP! On Sun, May 19, 2019 at 6:36 PM Dongjin Lee wrote: > +1 (non-binding). > > Binding: +2 (Randall, Gwen) > Non-binding: +2 (Andrew, Dongjin) > > We need one more +1 from the committers. Is there anyone else? > > Thanks, > Dongjin > > On Fri, May 10, 2019 at 12

Re: [VOTE] KIP-440: Extend Connect Converter to support headers

2019-05-19 Thread Dongjin Lee
+1 (non-binding). Binding: +2 (Randall, Gwen) Non-binding: +2 (Andrew, Dongjin) We need one more +1 from the committers. Is there anyone else? Thanks, Dongjin On Fri, May 10, 2019 at 12:16 AM Andrew Schofield wrote: > +1 (non-binding). > > Looks good. > > On 09/05/2019, 15:55, "Gwen Shapira"

[jira] [Created] (KAFKA-8391) Flaky Test RebalanceSourceConnectorsIntegrationTest#testDeleteConnector

2019-05-19 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created KAFKA-8391: -- Summary: Flaky Test RebalanceSourceConnectorsIntegrationTest#testDeleteConnector Key: KAFKA-8391 URL: https://issues.apache.org/jira/browse/KAFKA-8391 Project: Ka

Re: [DISCUSS] KIP-459: Improve KafkaStreams#close

2019-05-19 Thread Dongjin Lee
Hi Matthias, I investigated the inconsistencies between `close` semantics of `Producer`, `Consumer`, and `AdminClient`. And I found that this inconsistency was intended. Here are the details: The current `KafkaConsumer#close`'s default timeout, 30 seconds, was introduced in KIP-102 (0.10.2.0)[^1]