Re: Low-latency, high message size variance

Jason, maybe useful to KAFKA-2986 with this information if we ever decide to do this? Ismael On 16 Dec 2015 04:42, "Jason Gustafson" wrote: > I was talking with Jay this afternoon about this use case. The tricky thing > about adding a ping() or heartbeat() API is that you

Re: compression-rate-avg returns 0 with compression enabled

Yes, please. Ismael On 15 Dec 2015 11:52, "tao xiao" wrote: > Hi team, > > I found that the producer metric compression-rate-avg always returns 0 even > with compression.type set to snappy. I drilled down the code and discovered > that the position of bytebuffer in >

Re: Mirrormaker issue with Kafka 0.9 (confluent platform 2.0)

On Fri, Dec 11, 2015 at 3:31 AM, Guozhang Wang wrote: > As Ewen said in KAFKA-1650 we removed the support of multiple consumer > configs in MM, so that you cannot get one MM instance to pull from multiple > origin clusters, but instead you need to use one MM instance for each

Re: SSL - kafka producer cannot publish to topic

Hi Shrikant, On Thu, Dec 10, 2015 at 9:03 PM, Shrikant Patel wrote: > Figured it out. > > I was adding the ssl properties to producer.properties. We need to add > this to separate file and provide that file as input to procuder bat\sh > script --producer.config

Re: 0.9.0.0 RC4

+1 (non-binding). Verified source and binary artifacts, ran ./gradlew testAll with JDK 7u80, quick start on source artifact and Scala 2.11 binary artifact. On Sat, Nov 21, 2015 at 1:21 AM, Jun Rao wrote: > This is the fourth candidate for release of Apache Kafka 0.9.0.0.

Re: 0.9.0.0 RC4

On Mon, Nov 23, 2015 at 4:15 PM, hsy...@gmail.com wrote: > In http://kafka.apache.org/090/documentation.html#newconsumerconfigs > partition.assignment.strategy should string, not a list of string? > List is correct, I believe, see how it's used in the code: List assignors =

Re: [VOTE] 0.9.0.0 Candiate 3

+1 (non-binding). Verified source and binary artifacts, ran ./gradlew testAll with JDK 7u80, quick start on source artifact and Scala 2.11 binary artifact. Ismael On Wed, Nov 18, 2015 at 5:57 AM, Jun Rao wrote: > This is the third candidate for release of Apache Kafka

Re: secure communication between producer/consumer to brokers

SSL will be supported in 0.9.0.0, so please use trunk of you'd like to test it in the meantime. Ismael On 28 Oct 2015 12:09, "Pratapi Hemant Patel" wrote: > Hi all, > I followed the wiki > https://cwiki.apache.org/confluence/display/KAFKA/Deploying+SSL+for+Kafka > for

Re: [ANNOUCE] Apache Kafka 0.8.2.2 Released

On Sat, Oct 3, 2015 at 4:36 PM, Jun Rao wrote: > > We will update the download link in our website shortly. > The download page has been updated: http://kafka.apache.org/downloads.html Ismael

Re: 0.9.0.0 remaining jiras

Do we want to deprecate anything before 0.9.0 is released? Maybe the old producer? Ismael On Thu, Sep 17, 2015 at 8:07 PM, Dong Lin wrote: > Hey Jun, > > Should we also include https://issues.apache.org/jira/browse/KAFKA-2390 in > 0.9.0? Becket told me that this is one of

Re: Patch for SSL setup for Kafka

Hi LCassa, The SSL/TLS patch was recently merged to trunk, so it should be easier to test. Best, Ismael On Wed, Aug 19, 2015 at 12:54 AM, Cassa L lcas...@gmail.com wrote: Thank You! I will look into it. On Tue, Aug 18, 2015 at 10:34 AM, Sriharsha Chintalapani ka...@harsha.io wrote: Hi ,

Re: [DISCUSSION] Kafka 0.8.2.2 release?

I think this is a good idea as the change is minimal on our side and it has been tested in production for some time by the reporter. Best, Ismael On Fri, Aug 14, 2015 at 1:15 PM, Jun Rao j...@confluent.io wrote: Hi, Everyone, Since the release of Kafka 0.8.2.1, a number of people have

Re: Dropping support for Scala 2.9.x

to work or do we want to focus our efforts on 2.10 and 2.11? Please share your opinion. Best, Ismael [1] https://issues.apache.org/jira/browse/KAFKA-2325 On Fri, Mar 27, 2015 at 2:20 PM, Ismael Juma mli...@juma.me.uk wrote: Hi all, The Kafka build currently includes support for Scala 2.9

Dropping support for Scala 2.9.x

Hi all, The Kafka build currently includes support for Scala 2.9, which means that it cannot take advantage of features introduced in Scala 2.10 or depend on libraries that require it. This restricts the solutions available while trying to solve existing issues. I was browsing JIRA looking for

<    1   2   3   4   5