Re: [VOTE] KIP-276 Add StreamsConfig prefix for different consumers

+1 Original message From: Guozhang Wang Date: 4/18/18 10:18 PM (GMT-08:00) To: dev@kafka.apache.org Subject: Re: [VOTE] KIP-276 Add StreamsConfig prefix for different consumers Thanks Boyang, +1 from me. On Wed, Apr 18, 2018 at 4:43 PM, Boyang Chen wrote: > Hey guys, > > >

Re: [VOTE] Kafka 2.0.0 in June 2018

+1 (non binding), thanks On Wed, Apr 18, 2018 at 11:21 PM, Rahul Singh wrote: > +1 > > On Apr 18, 2018, 5:12 PM -0500, Bill Bejeck , wrote: >> +1 >> >> Thanks, >> Bill >> >> On Wed, Apr 18, 2018 at 6:07 PM, Edoardo Comar wrote: >> >> > thanks Ismael >> > >> > +1 (non-binding) >> > >> > -

Re: [VOTE] Kafka 2.0.0 in June 2018

+1 (binding) On Wed, Apr 18, 2018 at 11:35 AM, Ismael Juma wrote: > Hi all, > > I started a discussion last year about bumping the version of the June 2018 > release to 2.0.0[1]. To reiterate the reasons in the original post: > > 1. Adopt KIP-118 (Drop Support for Java 7), which requires a major

[jira] [Created] (KAFKA-6804) Event values should not be included in log messages

Jussi Lyytinen created KAFKA-6804: - Summary: Event values should not be included in log messages Key: KAFKA-6804 URL: https://issues.apache.org/jira/browse/KAFKA-6804 Project: Kafka Issue Typ

Re: [VOTE] Kafka 2.0.0 in June 2018

+1 (non binding). Thanks Ismael! On Thu., 19 Apr. 2018, 2:47 pm Gwen Shapira, wrote: > +1 (binding) > > On Wed, Apr 18, 2018 at 11:35 AM, Ismael Juma wrote: > > > Hi all, > > > > I started a discussion last year about bumping the version of the June > 2018 > > release to 2.0.0[1]. To reiterate

Re: [VOTE] Kafka 2.0.0 in June 2018

+1 (non-binding). Thanks. On Thu, Apr 19, 2018 at 3:07 PM, Stephane Maarek < steph...@simplemachines.com.au> wrote: > +1 (non binding). Thanks Ismael! > > On Thu., 19 Apr. 2018, 2:47 pm Gwen Shapira, wrote: > > > +1 (binding) > > > > On Wed, Apr 18, 2018 at 11:35 AM, Ismael Juma wrote: > > > >

Re: [VOTE] KIP-276 Add StreamsConfig prefix for different consumers

+1 (binding) -Matthias On 4/19/18 9:08 AM, Ted Yu wrote: > +1 > Original message From: Guozhang Wang > Date: 4/18/18 10:18 PM (GMT-08:00) To: dev@kafka.apache.org Subject: Re: > [VOTE] KIP-276 Add StreamsConfig prefix for different consumers > Thanks Boyang, +1 from me. >

[jira] [Created] (KAFKA-6805) Allow dynamic broker configs to be configured in ZooKeeper before starting broker

Rajini Sivaram created KAFKA-6805: - Summary: Allow dynamic broker configs to be configured in ZooKeeper before starting broker Key: KAFKA-6805 URL: https://issues.apache.org/jira/browse/KAFKA-6805 Pro

Re: [VOTE] KIP-276 Add StreamsConfig prefix for different consumers

Thanks guys！ Sent from my iPhone > On Apr 19, 2018, at 8:28 PM, Matthias J. Sax wrote: > > +1 (binding) > > -Matthias > >> On 4/19/18 9:08 AM, Ted Yu wrote: >> +1 >> Original message From: Guozhang Wang >> Date: 4/18/18 10:18 PM (GMT-08:00) To: dev@kafka.apache.org Subjec

[jira] [Created] (KAFKA-6806) Unable to validate sink connectors without "topics" component which is not required

Ivan Majnarić created KAFKA-6806: Summary: Unable to validate sink connectors without "topics" component which is not required Key: KAFKA-6806 URL: https://issues.apache.org/jira/browse/KAFKA-6806 Pro

Re: [DISCUSS]KIP-216: IQ should throw different exceptions for different errors

Thanks for clarification! That makes sense to me. Can you update the KIP to make those suggestions explicit? -Matthias On 4/18/18 2:19 PM, vito jeng wrote: > Matthias, > > Thanks for the feedback! > >> It's up to you to keep the details part in the KIP or not. > > Got it! > >> The (incomple

Re: [VOTE] Kafka 2.0.0 in June 2018

+1 (non binding), thanks Ismael! El jue., 19 abr. 2018 a las 13:01, Manikumar () escribió: > +1 (non-binding). > > Thanks. > > On Thu, Apr 19, 2018 at 3:07 PM, Stephane Maarek < > steph...@simplemachines.com.au> wrote: > > > +1 (non binding). Thanks Ismael! > > > > On Thu., 19 Apr. 2018, 2:47 pm

Re: [VOTE] Kafka 2.0.0 in June 2018

+1 (non-binding). Thanks Ismael. --Vahid From: Jorge Esteban Quilcate Otoya To: dev@kafka.apache.org Date: 04/19/2018 07:32 AM Subject:Re: [VOTE] Kafka 2.0.0 in June 2018 +1 (non binding), thanks Ismael! El jue., 19 abr. 2018 a las 13:01, Manikumar () escribió: > +1 (non-

Re: [DISCUSS] KIP-255: OAuth Authentication via SASL/OAUTHBEARER

Hi Rajini. Thanks for the feedback. I will adopt all of the suggestions. Regarding your question about moving the refresh config values out of the JAAS config and making them generic, yes, I think that would work, and it does advance us down the road toward an eventual unification. I'll post aga

Re: [VOTE] Kafka 2.0.0 in June 2018

+1 non-binding. thx Ismael On Thu, 19 Apr 2018 at 23:14 Vahid S Hashemian wrote: > +1 (non-binding). > > Thanks Ismael. > > --Vahid > > > > From: Jorge Esteban Quilcate Otoya > To: dev@kafka.apache.org > Date: 04/19/2018 07:32 AM > Subject:Re: [VOTE] Kafka 2.0.0 in June 2018 > >

[jira] [Created] (KAFKA-6807) Inconsistent method name

KuiLIU created KAFKA-6807: - Summary: Inconsistent method name Key: KAFKA-6807 URL: https://issues.apache.org/jira/browse/KAFKA-6807 Project: Kafka Issue Type: Improvement Reporter: KuiLIU

Re: [DISCUSS] KIP-285: Connect Rest Extension Plugin

On Thu, Apr 12, 2018 at 10:59 AM, Magesh Nandakumar wrote: > Hi Randall, > > Thanks a lot for your feedback. > > I will update the KIP to reflect your comments in (1), (2), (7) and (8). > Looking forward to these. > > For comment # (3) , while it would be great to automatically configure the >

[jira] [Created] (KAFKA-6808) Creating source Kafka connectors re-using a name of a deleted connector causes the connector to never push messages to kafka

Igor Candido created KAFKA-6808: --- Summary: Creating source Kafka connectors re-using a name of a deleted connector causes the connector to never push messages to kafka Key: KAFKA-6808 URL: https://issues.apache.org/

Re: [DISCUSSION] KIP-266: Add TimeoutException to KafkaConsumer#position()

Hi Richard, Thanks for the invitation! I do think it would be safer to introduce a new poll method than to change the semantics of the old one. I've been mulling about whether the new one could still have (slightly different) async semantics with a timeout of 0. If possible, I'd like to avoid intr

Re: [DISCUSSION] KIP-266: Add TimeoutException to KafkaConsumer#position()

John: In case you want to pursue async poll, it seems (by looking at current API) that introducing PollCallback follows existing pattern(s). e.g. KafkaConsumer#commitAsync(OffsetCommitCallback) FYI On Thu, Apr 19, 2018 at 10:08 AM, John Roesler wrote: > Hi Richard, > > Thanks for the invitatio

Re: [DISCUSS] KIP-285: Connect Rest Extension Plugin

Hi Randall, Thanks for your feedback. I also would like to go with rest.extension.classes`. For exposing Configurable, my original intention was just to expose that to the extension because that's all one needs to register JAX RS resources. The fact that we use Jersey shouldn't even be exposed in

Re: [VOTE] Kafka 2.0.0 in June 2018

+1 (non-binding). TY! On Thu, Apr 19, 2018 at 11:56 AM, tao xiao wrote: > +1 non-binding. thx Ismael > > On Thu, 19 Apr 2018 at 23:14 Vahid S Hashemian > wrote: > > > +1 (non-binding). > > > > Thanks Ismael. > > > > --Vahid > > > > > > > > From: Jorge Esteban Quilcate Otoya > > To: dev@k

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

See Changes: [wangguoz] MINOR: Retry setting aligned time until set (#4893) -- [...truncated 415.96 KB...] kafka.admin.ResetConsumerGroupOffsetTest > testResetOffsetsShif

Build failed in Jenkins: kafka-trunk-jdk10 #35

See Changes: [wangguoz] MINOR: Retry setting aligned time until set (#4893) -- [...truncated 1.48 MB...] kafka.api.SaslClientsWithInvalidCredentialsTest > testTransaction

Re: [DISCUSSION] KIP-266: Add TimeoutException to KafkaConsumer#position()

Thanks for the tip, Ted! On Thu, Apr 19, 2018 at 12:12 PM, Ted Yu wrote: > John: > In case you want to pursue async poll, it seems (by looking at current API) > that introducing PollCallback follows existing pattern(s). > > e.g. KafkaConsumer#commitAsync(OffsetCommitCallback) > > FYI > > On Thu,

[jira] [Created] (KAFKA-6809) connections-created metric does not behave as expected

Anna Povzner created KAFKA-6809: --- Summary: connections-created metric does not behave as expected Key: KAFKA-6809 URL: https://issues.apache.org/jira/browse/KAFKA-6809 Project: Kafka Issue Type

Jenkins build is back to normal : kafka-trunk-jdk10 #36

See

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

See

Build failed in Jenkins: kafka-trunk-jdk7 #3357

See Changes: [github] MINOR: add window store range query in simple benchmark (#4894) -- [...truncated 1.93 MB...] org.apache.kafka.streams.tools.StreamsResetterTest > t

[jira] [Resolved] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`

[ https://issues.apache.org/jira/browse/KAFKA-6592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6592. -- Resolution: Fixed Thanks for the reminder! > NullPointerException thrown when executing Console

Re: [DISCUSS] KIP-285: Connect Rest Extension Plugin

Hi All, I have updated the KIP with following changes 1. Expanded the Motivation section 2. Included details about the interface in the public interface section 3. Modified the config name to rest.extension.classes 4. Modified the ConnectRestExtension to include Configurable instead o

Re: [VOTE] KIP-281: ConsumerPerformance: Increase Polling Loop Timeout and Make It Reachable by the End User

+1 4 votes total: 1 binding vote (Jason Gustafson) 3 non-binding votes (Moshe Blumberg, Ted Yu, Alex Dunayevsky) Can we consider the voting closed? Thank you everyone! Alex Dunayevsky > Tue, 17 Apr 2018 23:28:35 GMT, Jason Gustafson wrote: > +1 (binding) > > On Tue, Apr 17, 2018 at