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

Thanks for updating the KIP and sorry for the long pause... Seems you did a very thorough investigation of the code. It's useful to understand what user facing interfaces are affected. (Some parts might be even too detailed for a KIP.) To summarize my current understanding of your KIP, the main c

[jira] [Created] (KAFKA-6764) ConsoleConsumer behavior inconsistent when specifying --partition --from-beginning

Larry McQueary created KAFKA-6764: - Summary: ConsoleConsumer behavior inconsistent when specifying --partition --from-beginning Key: KAFKA-6764 URL: https://issues.apache.org/jira/browse/KAFKA-6764 P

Re: Dead link in Kafka Streams documentation

Thanks Guozhang, everything works as expected now! Kind regards, Stephane [image: Simple Machines] Stephane Maarek | Developer +61 416 575 980 steph...@simplemachines.com.au simplemachines.com.au Level 2, 145 William Street, Sydney NSW 2010 On 8 April 2018 at 06:38, Guozhang Wang wrote: > I

Re: [DISCUSS] KIP-280: Enhanced log compaction

Luís, thanks a lot for this KIP. Very interesting idea. Couple of questions: - Why do we need two new configs? Why is the topic config `compaction.strategy` not sufficient? - For Kafka Streams we did think about a timestamp base compaction at some point (internal brain storming)---we never th

Re: Dead link in Kafka Streams documentation

I have pushed a hotfix PR for fixing the default version links in streams dev-guide. https://github.com/apache/kafka-site/commit/94f59b43d013dca2832fecfa1efe919f3b66ca90 Guozhang On Sat, Apr 7, 2018 at 5:55 PM, Guozhang Wang wrote: > Thanks for reporting the issue Stephane, I will fix it. > >

Re: Dead link in Kafka Streams documentation

Thanks for reporting the issue Stephane, I will fix it. Guozhang On Fri, Apr 6, 2018 at 10:15 PM, Stephane Maarek < steph...@simplemachines.com.au> wrote: > https://kafka.apache.org/documentation/streams/developer-guide/ > > "Testing a Streams application" points to > https://kafka.apache.org/d

Re: [DISCUSS] KIP-284 Set default retention ms for Streams repartition topics to Long.MAX_VALUE

Several sections, such as 'Public Interfaces', only contain template. Can you modify the KIP so that it is easier to read ? Thanks On Sat, Apr 7, 2018 at 2:57 PM, khaireddine Rezgui wrote: > Hi guys, > > I created this KIP to get your feedback about the new default value of the > retention_ms

[jira] [Created] (KAFKA-6763) Consider using direct byte buffers in SslTransportLayer

Ismael Juma created KAFKA-6763: -- Summary: Consider using direct byte buffers in SslTransportLayer Key: KAFKA-6763 URL: https://issues.apache.org/jira/browse/KAFKA-6763 Project: Kafka Issue Type:

Re: [DISCUSS] KIP-283 Set default retention ms for Streams repartition topics to Long.MAX_VALUE

Did you intend to say KIP-284 ? KIP-283 is for another proposal. Original message From: khaireddine Rezgui Date: 4/7/18 2:15 PM (GMT-08:00) To: dev@kafka.apache.org Subject: [DISCUSS] KIP-283 Set default retention ms for Streams repartition topics to Long.MAX_VALUE Hi guys,

[DISCUSS] KIP-284: Set default retention ms for Streams repartition topics to Long.MAX_VALUE

Hi guys, I created this KIP to get your feedback about the new default value of the retention_ms in kafka stream repartion topics. https://cwiki.apache.org/confluence/display/KAFKA/KIP- 284%3A+Set+default+retention+ms+for+Streams+repartition+ topics+to+Long.MAX_VALUE The kip in under constructio

[DISCUSS] KIP-284 Set default retention ms for Streams repartition topics to Long.MAX_VALUE

Hi guys, I created this KIP to get your feedback about the new default value of the retention_ms in kafka stream repartion topics. https://cwiki.apache.org/confluence/display/KAFKA/KIP-284%3A+Set+default+retention+ms+for+Streams+repartition+topics+to+Long.MAX_VALUE The kip in under construction

[DISCUSS] KIP-283 Set default retention ms for Streams repartition topics to Long.MAX_VALUE

Hi guys, i init this discution aboutSetting new default value for kafka stream repartion topic.

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

Hey Ewen, could you provide some feedback on Matthias and Guozhang's reply? We hope to clear your concern and reach common understanding eventually. Thanks! Best, Boyang From: Boyang Chen Sent: Friday, April 6, 2018 11:19 AM To: dev@kafka.apache.org Subject

[jira] [Created] (KAFKA-6762) log-cleaner thread terminates due to java.lang.IllegalStateException

Ricardo Bartolome created KAFKA-6762: Summary: log-cleaner thread terminates due to java.lang.IllegalStateException Key: KAFKA-6762 URL: https://issues.apache.org/jira/browse/KAFKA-6762 Project: K

[VOTE] KIP-148: Add a connect timeout for client

Hi All, I have started a vote for this KIP, for more details of the discussions, please refer to the previous e-mails. The KIP can be found at https://cwiki.apache.org/confluence/display/KAFKA/KIP-148%3A+Add+a+connect+timeout+for+client Thanks, David

Re: Re： [DISCUSS] KIP-148: Add a connect timeout for client

Can you start another thread with [VOTE] in the subject ? Original message From: 东方甲乙 <254479...@qq.com> Date: 4/7/18 6:10 AM (GMT-08:00) To: dev Subject: Re： [DISCUSS] KIP-148: Add a  connect timeout for client Hi all, Do you have further concerns or questions about this K

Re?? [DISCUSS] KIP-148: Add a connect timeout for client

Hi all, Do you have further concerns or questions about this KIP? If not, would you please vote for it? Thank you very much! Best, David -- -- ??: ""<254479...@qq.com>; : 2017??6??16??(??) 10:45 ??: "dev"; : Re?