Re: Configure Tomcat Server as Kafka Producer

2014-01-08 Thread Joe Stein
Does it have to be tomcat? We have been talking about adding an http endpoint to https://github.com/stealthly/scala-kafka as clients have been asking for a simple REST based producer ( with other stuff too but this also). /*** Joe Stein Founder, Princ

FW: Configure Tomcat Server as Kafka Producer

2014-01-08 Thread joseph.simmons
Hi, I was wondering if there is a tutorial to set this up? I'm trying to link a REST API transferring JSON to Kafka being consumed by Storm/Cassandra. I'm very new to Kafka/Scala/Storm, linux etc. Any direction would be greatly appreciated. Thank You, Joe Simmons

Re: KafkaController internals

2014-01-08 Thread Joe Stein
very helpful/useful, thanks Jun!!! /*** Joe Stein Founder, Principal Consultant Big Data Open Source Security LLC http://www.stealth.ly Twitter: @allthingshadoop / On

KafkaController internals

2014-01-08 Thread Jun Rao
For those who are interested, I documented how KafkaController works in the following wiki. https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Controller+Internals Thanks, Jun

[jira] [Created] (KAFKA-1202) optimize ZK access in KafkaController

2014-01-08 Thread Jun Rao (JIRA)
Jun Rao created KAFKA-1202: -- Summary: optimize ZK access in KafkaController Key: KAFKA-1202 URL: https://issues.apache.org/jira/browse/KAFKA-1202 Project: Kafka Issue Type: Bug Components:

[jira] [Updated] (KAFKA-1200) inconsistent log levels when consumed offset is reset

2014-01-08 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1200: - Fix Version/s: 0.8.1 the consumer should log the error too, yeah. should be able to patch this too if n

Re: Review Request 16718: Patch for KAFKA-1180

2014-01-08 Thread Joe Stein
> On Jan. 8, 2014, 2:49 a.m., joel koshy wrote: > > core/src/main/scala/kafka/utils/Utils.scala, line 544 > > > > > > Thanks for patching this issue. > > > > I'm not very clear on the cases here - i.e., is it

[jira] [Commented] (KAFKA-1025) Producer.send should provide recoverability info on failiure

2014-01-08 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13865458#comment-13865458 ] Joe Stein commented on KAFKA-1025: -- Hi Jason, I have a developer on the bench for a few d