Re: Producer repeatedly locking up

2015-07-01 Thread Shayne S
The problem is gone, but I'm unsure of the root cause. The client library I use recently added support for the new producer. Switching to that seems to have sidestepped the problem. On Tue, Jun 30, 2015 at 12:53 PM, Shayne S wrote: > Thanks for responding Gwen. > > There is sometimes an error in

EOL JDK 1.6 for Kafka

2015-07-01 Thread Harsha
Hi, During our SSL Patch KAFKA-1690. Some of the reviewers/users asked for support this config https://docs.oracle.com/javase/8/docs/api/javax/net/ssl/SSLParameters.html#setEndpointIdentificationAlgorithm-java.lang.String- It allows clients to verify the server and prevent potentia

Re: Issue with log4j Kafka Appender.

2015-07-01 Thread Madhavi Sreerangam
I have added the configurations suggested, now my log4j appender file looks as follows log4j.appender.KAFKA=kafka.producer.KafkaLog4jAppender log4j.appender.KAFKA.BrokerList=iakafka301p.dev.ch3.s.com:9092, iakafka302p.dev.ch3.s.com:9092,iakafka303p.dev.ch3.s.com:9092 log4j.appender.KAFKA.Topic=d

Re: EOL JDK 1.6 for Kafka

2015-07-01 Thread Marina
+1 for deprecating JDK1.6 From: Harsha To: users@kafka.apache.org; d...@kafka.apache.org Sent: Wednesday, July 1, 2015 11:05 AM Subject: EOL JDK 1.6 for Kafka Hi,         During our SSL Patch KAFKA-1690. Some of the reviewers/users         asked for support this config https://docs

Re: EOL JDK 1.6 for Kafka

2015-07-01 Thread Joel Koshy
+1 On Wednesday, July 1, 2015, Harsha wrote: > Hi, > During our SSL Patch KAFKA-1690. Some of the reviewers/users > asked for support this config > > https://docs.oracle.com/javase/8/docs/api/javax/net/ssl/SSLParameters.html#setEndpointIdentificationAlgorithm-java.lang.String- >

Re: EOL JDK 1.6 for Kafka

2015-07-01 Thread Gwen Shapira
Huge +1. I don't think there is any other project that still supports 1.6. On Wed, Jul 1, 2015 at 8:05 AM, Harsha wrote: > Hi, > During our SSL Patch KAFKA-1690. Some of the reviewers/users > asked for support this config > https://docs.oracle.com/javase/8/docs/api/javax/net/ssl/

Re: EOL JDK 1.6 for Kafka

2015-07-01 Thread Jiangjie Qin
+1 On 7/1/15, 1:00 PM, "Gwen Shapira" wrote: >Huge +1. > >I don't think there is any other project that still supports 1.6. > >On Wed, Jul 1, 2015 at 8:05 AM, Harsha wrote: >> Hi, >> During our SSL Patch KAFKA-1690. Some of the reviewers/users >> asked for support this config >>

some problem abort isrshrinkrate

2015-07-01 Thread taosheng53
hello, when i use jmx to monitor kafka, i find the value of the isrshrinkrate always 0,never change when one broker has been shutdown.(i have a cluster containing three nodes),i want to know if there is some problem?

Re: Does kafka write key to broker?

2015-07-01 Thread Mohit Kathuria
Guozhang, Thanks for the reply. That's exactly what I was looking for. -Thanks, Mohit On Tue, Jun 30, 2015 at 1:52 AM, Guozhang Wang wrote: > Hi Mohit, > > The KeyedMessage has a "key" and "partKey" as it fields, and if the partKey > is not specified then key will be used as partKey by default