guangxian.liao created KAFKA-6405:
-
Summary: Fix incorrect comment in MetadataUpdater
Key: KAFKA-6405
URL: https://issues.apache.org/jira/browse/KAFKA-6405
Project: Kafka
Issue Type: Improvem
Yu Gan created KAFKA-6404:
-
Summary: OldConsumer FetchRequest apiVersion not match resulting
in broker RequestHandler socket leak
Key: KAFKA-6404
URL: https://issues.apache.org/jira/browse/KAFKA-6404
Project:
Hi all,
I would like to start the vote thread.
This is link for the kip.
https://cwiki.apache.org/confluence/display/KAFKA/KIP-233%3A+Simplify+StreamsBuilder%23addGlobalStore
Cheers
Thanks for the KIP, +1 from me.
On Wed, Dec 27, 2017 at 7:42 AM, Bill Bejeck wrote:
> Thanks for the KIP. +1 for me.
>
> On Tue, Dec 26, 2017 at 6:22 PM Ted Yu wrote:
>
> > +1 from me as well.
> >
> > On Tue, Dec 26, 2017 at 10:41 AM, Matthias J. Sax >
> > wrote:
> >
> > > Thanks for the KIP
change created KAFKA-6403:
-
Summary: Why kafka sync send message with 10 seconds delay
Key: KAFKA-6403
URL: https://issues.apache.org/jira/browse/KAFKA-6403
Project: Kafka
Issue Type: Test
Affec
Hi Todd,
That worked. Basically I used a python library to read the leaders of a
topic/partition from the following path on zookeeper:
/brokers/topics/[topic]/partitions/[partitionId]/state.
Then I was able to get the correct leader and assign the replica set so
that the current leader remains th
We have a use case where in we want to assign partitions manually for a set
of topics to allow fine grained control of the records we are fetching.
Basically what we are trying to achieve is that a group of messages which
logically belong to a particular entity should be sent to the same
partition
Thanks for the KIP. +1 for me.
On Tue, Dec 26, 2017 at 6:22 PM Ted Yu wrote:
> +1 from me as well.
>
> On Tue, Dec 26, 2017 at 10:41 AM, Matthias J. Sax
> wrote:
>
> > Thanks for the KIP Boyang!
> >
> > I don't have any further comments.
> >
> > +1 from me.
> >
> > @Ted: This is a rather simpl
+1 from me as well.
On Tue, Dec 26, 2017 at 10:41 AM, Matthias J. Sax
wrote:
> Thanks for the KIP Boyang!
>
> I don't have any further comments.
>
> +1 from me.
>
> @Ted: This is a rather simple KIP, thus, skipping the DISCUSS thread
> seems ok to me.
>
>
>
> -Matthias
>
>
> @Boyang: it's recomm
Greetings.
Thanks for the comments and suggestions. I updated the KIP with these
proposals for the questions posed by Matt & Matthias:
*Can you please c&p the corresponding content instead of just
putting links? A KIP should be a self-contained Wiki page. Also, if we add
a optional config paramet
Thanks for the KIP Jorge,
As Bill pointed out already, we should be careful with adding new
overloads as this contradicts the work done via KIP-182.
This KIP also seems to be related to KIP-149 and KIP-159. Are you aware
of them? Both have quite long DISCUSS threads, but it might be worth
browsin
Thanks for the KIP Boyang!
I don't have any further comments.
+1 from me.
@Ted: This is a rather simple KIP, thus, skipping the DISCUSS thread
seems ok to me.
-Matthias
@Boyang: it's recommended to use this format for the subject
"[VOTE] KIP-245: ..."
Same for DISCUSS threads. People are
[
https://issues.apache.org/jira/browse/KAFKA-6402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6402.
Resolution: Duplicate
> KStream Ktable join integration test fails randomly
> --
[
https://issues.apache.org/jira/browse/KAFKA-6401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-6401.
Resolution: Not A Problem
> InvalidStateStoreException immediately after starting streams
>
Does anyone have any thoughts about this proposal for Connect header
support?
On Thu, Dec 21, 2017 at 4:14 PM, Randall Hauch wrote:
> All,
>
> I've updated KIP-145 to reflect my proposal. The proposal addresses SMTs
> and a different HeaderConverter default, but I'll be updating my PR (
> https:
Narendra Kumar created KAFKA-6402:
-
Summary: KStream Ktable join integration test fails randomly
Key: KAFKA-6402
URL: https://issues.apache.org/jira/browse/KAFKA-6402
Project: Kafka
Issue Typ
Normally a DISCUSS thread precedes VOTE thread so that people have ample time
examining the proposal.
Original message From: Boyang Chen Date:
12/26/17 1:22 AM (GMT-07:00) To: dev@kafka.apache.org Subject: Vote for
KIP-245: Use Properties instead of StreamsConfig in KafkaStre
Mostafa Asgari created KAFKA-6401:
-
Summary: InvalidStateStoreException immediately after starting
streams
Key: KAFKA-6401
URL: https://issues.apache.org/jira/browse/KAFKA-6401
Project: Kafka
Hi there,
I'm Boyang who is a newbie contributor to Kafka. I would like to start a vote
for the KIP-245:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-245%3A+Use+Properties+instead+of+StreamsConfig+in+KafkaStreams+constructor
This is linked with JIRA: https://issues.apache.org/jira/bro
19 matches
Mail list logo
