Yes probably, but ATM, I've just been trying to get it to work at all. Fixing issues like that is on the way...
On Tue, Feb 5, 2013 at 7:38 AM, S Ahmed <sahmed1...@gmail.com> wrote: > Shouldn't your producer be at the controller scope? Instantiating it every > time is probably nto the correct pattern. You probably want to use a asych > producer also right? > > > > > On Mon, Feb 4, 2013 at 7:12 PM, charlie w <spambait...@gmail.com> wrote: > >> It seems the issue is related to Scala versions. I grabbed from >> https://github.com/kevinwright/kafka >> and built with >> sbt "++2.10.0 package" >> >> I'm able to have my Play app produce messages for Kafka now. >> >> >> On Fri, Feb 1, 2013 at 5:32 PM, charlie w <spambait...@gmail.com> wrote: >> > Is it possible to have a Kafka 0.8 producer inside a Play Framework >> > controller? (I am new to both Kafka and Play.) >> > >> > I have managed to get Java code cribbed from the Kafka examples >> > (below) to compile and execute within Play, but constructing the >> > ProducerConfig object never returns. I am not finding anything in any >> > Play log. >> > >> > I've also tried this using the Scala console producer as a model and >> > had the same result >> > >> > The Kafka console producer and consumer samples are working for me. >> > >> > Thanks >> > Charlie >> > >> > code: >> > >> > >> > package controllers; >> > >> > import java.util.Properties; >> > >> > import kafka.producer.ProducerConfig; >> > import kafka.javaapi.producer.Producer; >> > import kafka.producer.KeyedMessage; >> > >> > public class Hello >> > { >> > public static void hello( String v ) >> > { >> > Properties props = new Properties(); >> > props.put("zk.connect", "127.0.0.1:2181"); >> > props.put("serializer.class", "kafka.serializer.StringEncoder"); >> > props.put("broker.list", "localhost:9092" ); >> > >> > play.Logger.info("create config"); >> > ProducerConfig config = new ProducerConfig(props); >> > >> > play.Logger.info("create producer"); >> > Producer<Integer, String> producer = new Producer<Integer, >> > String>(config); >> > >> > play.Logger.info("yay!"); >> > >> > KeyedMessage msg = new KeyedMessage<Integer, >> > String>("test-topic", "Greetings!"); >> > >> > producer.send( msg ); >> > } >> > } >>
