Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> Producer SSL?


Copy link to this message
-
Re: Producer SSL?
I echo Jason's question.  That would be much easier than using something
like stunnel.
On Fri, Nov 15, 2013 at 11:41 AM, Jason Rosenberg <[EMAIL PROTECTED]> wrote:

> Is this something you can make available/open source?
>
>
> On Fri, Nov 15, 2013 at 1:03 PM, Rajasekar Elango <[EMAIL PROTECTED]
> >wrote:
>
> > Hi Jonathan
> >
> > We forked kafka to add SSL feature. It not part of kafka official release
> >
> > Sent from my iPhone
> >
> > On Nov 15, 2013, at 12:32 PM, Jonathan Hodges <[EMAIL PROTECTED]> wrote:
> >
> > > Hi,
> > >
> > > While searching the user group messages I found the following thread -
> > >
> >
> http://grokbase.com/t/kafka/users/138vqq1x07/getting-leadernotavailableexception-in-console-producer-after-increasing-partitions-from-4-to-16
> > .
> > > It shows the following stack trace with 0.8.
> > >
> > > [2013-08-27 08:29:30,372] INFO Fetching metadata from broker
> > > id:0,host:localhost,port:6667,secure:true with correlation id 8 for 1
> > > topic(s) Set(test-41) (kafka.client.ClientUtils$)
> > > [2013-08-27 08:29:30,373] INFO begin ssl handshake for localhost/
> > > 127.0.0.1:6667//127.0.0.1:36640 (kafka.security.SSLSocketChannel)
> > > [2013-08-27 08:29:30,375] INFO finished ssl handshake for localhost/
> > > 127.0.0.1:6667//127.0.0.1:36640 (kafka.security.SSLSocketChannel)
> > > [2013-08-27 08:29:30,375] INFO Connected to localhost:6667:true for
> > > producing (kafka.producer.SyncProducer)
> > > [2013-08-27 08:29:30,380] INFO Disconnecting from localhost:6667:true
> > > (kafka.producer.SyncProducer)
> > > [2013-08-27 08:29:30,381] INFO Secure sockets for data transfer is
> > enabled
> > > (kafka.producer.SyncProducerConfig)
> > >
> > > Is there a 'secure' boolean property on the broker that allows for SSL?
> >  I
> > > didn't see it on http://kafka.apache.org/08/configuration.html but
> > maybe I
> > > missed it?
> > >
> > > Thanks,
> > > Jonathan
> >
>

 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB