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, > > > sorry I forgot to include a summary of this KIP. Basically the idea is to > separate the stream config for different internal consumers of Kafka > Streams by supplying prefixes . We currently have >

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

See Changes: [wangguoz] KAFKA-6802: Improved logging for missing topics during task assignment -- [...truncated 417.50 KB...] kafka.admin.ResetConsumerGroupOffsetTest >

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

Hey guys, sorry I forgot to include a summary of this KIP. Basically the idea is to separate the stream config for different internal consumers of Kafka Streams by supplying prefixes . We currently have (1) "main.consumer." for the main consumer (2) "restore.consumer." for the restore consum

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

See Changes: [wangguoz] KAFKA-6775: Fix the issue of without init super class's (#4859) -- [...truncated 415.46 KB...] kafka.server.epoch.LeaderEpochFileCacheTest > shou

Re: [VOTE] Kafka 2.0.0 in June 2018

+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) > > > > -- > > > > Edoardo Comar > > > > IBM Message Hub > > > > I

Re: [VOTE] Kafka 2.0.0 in June 2018

+1 Thanks, Bill On Wed, Apr 18, 2018 at 6:07 PM, Edoardo Comar wrote: > thanks Ismael > > +1 (non-binding) > > -- > > Edoardo Comar > > IBM Message Hub > > IBM UK Ltd, Hursley Park, SO21 2JN > > > > From: Rajini Sivaram > To: dev > Date:

Re: [VOTE] Kafka 2.0.0 in June 2018

+1 (non-binding) ... I think that both points make lot of sense. Jakub On Thu, Apr 19, 2018 at 12:07 AM, Edoardo Comar wrote: > thanks Ismael > > +1 (non-binding) > > -- > > Edoardo Comar > > IBM Message Hub > > IBM UK Ltd, Hursley Park, SO21 2JN

[jira] [Resolved] (KAFKA-6775) AbstractProcessor created in SimpleBenchmark should call super#init

[ https://issues.apache.org/jira/browse/KAFKA-6775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6775. -- Resolution: Fixed Fix Version/s: 1.2.0 > AbstractProcessor created in SimpleBenchmark sho

Re: [VOTE] Kafka 2.0.0 in June 2018

thanks Ismael +1 (non-binding) -- Edoardo Comar IBM Message Hub IBM UK Ltd, Hursley Park, SO21 2JN From: Rajini Sivaram To: dev Date: 18/04/2018 22:05 Subject:Re: [VOTE] Kafka 2.0.0 in June 2018 Hi Ismael, Thanks for foll

[jira] [Created] (KAFKA-6803) Caching is turned off for stream-stream Join

Guozhang Wang created KAFKA-6803: Summary: Caching is turned off for stream-stream Join Key: KAFKA-6803 URL: https://issues.apache.org/jira/browse/KAFKA-6803 Project: Kafka Issue Type: Improv

Re: [VOTE] KIP-270 A Scala wrapper library for Kafka Streams

The voting process for KIP-270 A Scala wrapper library for Kafka Streams has generated 5 binding and 4 non binding votes with no objections. Thanks for all the reviews and feedbacks. Regards. On Mon, 16 Apr 2018 at 9:28 PM, Guozhang Wang wrote: > Thanks Debasish for the KIP! > > Will make anot

Re: [VOTE] Kafka 2.0.0 in June 2018

Hi Ismael, Thanks for following this up. +1 (binding) Regards, Rajini On Wed, Apr 18, 2018 at 8:09 PM, Ted Yu wrote: > +1 > Original message From: Ismael Juma > Date: 4/18/18 11:35 AM (GMT-08:00) To: dev > Subject: [VOTE] Kafka 2.0.0 in June 2018 > Hi all, > > I started

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

See Changes: [jason] KAFKA-3365; Add documentation method for protocol types and update doc -- [...truncated 3.96 MB...] org.apache.kafka.streams.processor.internals.Proce

[jira] [Reopened] (KAFKA-2334) Prevent HW from going back during leader failover

[ https://issues.apache.org/jira/browse/KAFKA-2334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reopened KAFKA-2334: > Prevent HW from going back during leader failover > -

Re: [VOTE] KIP-275 - Indicate "isClosing" in the SinkTaskContext

+1 On Wed, Apr 18, 2018 at 12:40 PM, Matt Farmer wrote: > Good afternoon/evening/morning all: > > I'd like to start voting on KIP-275: Indicate "isClosing" in the > SinkTaskContext > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=75977607 > > I'm going to start preparing the pa

[VOTE] KIP-275 - Indicate "isClosing" in the SinkTaskContext

Good afternoon/evening/morning all: I'd like to start voting on KIP-275: Indicate "isClosing" in the SinkTaskContext https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=75977607 I'm going to start preparing the patch we've been using internally for PR and get it up for review later t

Re: [VOTE] Kafka 2.0.0 in June 2018

+1 Original message From: Ismael Juma Date: 4/18/18 11:35 AM (GMT-08:00) To: dev Subject: [VOTE] Kafka 2.0.0 in June 2018 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:

[VOTE] Kafka 2.0.0 in June 2018

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 version bump due to semantic versioning. 2. Take the chance to remove depreca

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

See

[jira] [Created] (KAFKA-6802) Improve logging when topics aren't known and assignments skipped

Bill Bejeck created KAFKA-6802: -- Summary: Improve logging when topics aren't known and assignments skipped Key: KAFKA-6802 URL: https://issues.apache.org/jira/browse/KAFKA-6802 Project: Kafka I

[jira] [Resolved] (KAFKA-3365) Add a documentation field for types and update doc generation

[ https://issues.apache.org/jira/browse/KAFKA-3365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-3365. Resolution: Fixed > Add a documentation field for types and update doc generation >

RE: [VOTE] KIP-235 Add DNS alias support for secured connection

I have updated the KIP with more details, thanks. Jonathan Skrzypek -Original Message- From: Ted Yu [mailto:yuzhih...@gmail.com] Sent: 16 April 2018 16:02 To: dev@kafka.apache.org Subject: Re: [VOTE] KIP-235 Add DNS alias support for secured connection Looks good to me. BTW KAFKA-619

[jira] [Created] (KAFKA-6801) Restrict Consumer to fetch data from secure port only, and deny from non-secure port.

VinayKumar created KAFKA-6801: - Summary: Restrict Consumer to fetch data from secure port only, and deny from non-secure port. Key: KAFKA-6801 URL: https://issues.apache.org/jira/browse/KAFKA-6801 Project

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

See Changes: [rajinisivaram] KAFKA-6772: Load credentials from ZK before accepting connections -- [...truncated 375.81 KB...] kafka.producer.SyncProducerTest > testProducer

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

Matthias, Thanks for the feedback! > It's up to you to keep the details part in the KIP or not. Got it! > The (incomplete) question was, if we need `StateStoreFailException` or > if existing `InvalidStateStoreException` could be used? Do you suggest > that `InvalidStateStoreException` is not th

Failure broker

Hi, i have a cluster of 5 broker. I created 10 topic with 5 replica factor and 5 partitions. When one broker is shutdown, the cluster not working. Why? Can you help me? I await your response Thanks!!

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

Hi Ron, A few more suggestions and questions: 1. The KIP says that various callback handlers and login have to be configured in order to use OAuth. Could we also say that a default implementation is included which is not suitable for production use, but this would work out-of-the-box

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

See Changes: [github] KAFKA-6772: Load credentials from ZK before accepting connections -- [...truncated 1.48 MB...] kafka.admin.ResetConsumerGroupOffsetTest > testResetOff

[jira] [Created] (KAFKA-6800) Update documentation for SASL/PLAIN and SCRAM to use callbacks

Rajini Sivaram created KAFKA-6800: - Summary: Update documentation for SASL/PLAIN and SCRAM to use callbacks Key: KAFKA-6800 URL: https://issues.apache.org/jira/browse/KAFKA-6800 Project: Kafka

[jira] [Resolved] (KAFKA-1716) hang during shutdown of ZookeeperConsumerConnector

[ https://issues.apache.org/jira/browse/KAFKA-1716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1716. -- Resolution: Auto Closed Closing inactive issue. The Scala consumers have been deprecated and no further

Jenkins build is back to normal : kafka-trunk-jdk7 #3351

See

[jira] [Resolved] (KAFKA-5287) Messages getting repeated in kafka

[ https://issues.apache.org/jira/browse/KAFKA-5287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5287. -- Resolution: Cannot Reproduce Closing inactive issue. Please reopen with more details., if you think the

[jira] [Resolved] (KAFKA-6772) Broker should load credentials from ZK before requests are allowed

[ https://issues.apache.org/jira/browse/KAFKA-6772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-6772. --- Resolution: Fixed Reviewer: Jun Rao > Broker should load credentials from ZK before requ

[jira] [Resolved] (KAFKA-5262) Can't find some consumer group information

[ https://issues.apache.org/jira/browse/KAFKA-5262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5262. -- Resolution: Cannot Reproduce Closing inactive issue. Please reopen with more details., if you think the

[jira] [Resolved] (KAFKA-3476) -Xloggc is not recognised by IBM java

[ https://issues.apache.org/jira/browse/KAFKA-3476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3476. -- Resolution: Won't Fix Closing this as we can export the GC values and performance opts. Please reopen

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

See

[jira] [Resolved] (KAFKA-6107) SCRAM user add appears to fail if Kafka has never been started

[ https://issues.apache.org/jira/browse/KAFKA-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6107. -- Resolution: Fixed Fix Version/s: 1.1.0 This was fixed in KafkaZkClient changes work. > SCRAM use