You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Joe Stein (JIRA)" <ji...@apache.org> on 2013/10/23 21:51:43 UTC
[jira] [Commented] (KAFKA-1101) Need better java api for embedding
kafkaserver in a java container app
[ https://issues.apache.org/jira/browse/KAFKA-1101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13803227#comment-13803227 ]
Joe Stein commented on KAFKA-1101:
----------------------------------
[~jbrosenberg@gmail.com] What would you like to see it look more like?
//something like
server = new kafka.server.KafkaServer(kafkaConfig);
server.startup();
I have been writing Java/Scala layers with Cassandra lately will be doing that some more with Kafka now too.
I might be wrong but I think we would need a java based jar wrapping the kafka scala jar to un-abstract the byte codes representations?
So we would have a pom (or ant/ivy or gradle or whatever) for building this kafka-java.jar which would wrap the kafka scala jar and provide more Java like code wrapped for java clients?
> Need better java api for embedding kafkaserver in a java container app
> ----------------------------------------------------------------------
>
> Key: KAFKA-1101
> URL: https://issues.apache.org/jira/browse/KAFKA-1101
> Project: Kafka
> Issue Type: Bug
> Reporter: Jason Rosenberg
>
> We embed the KafkaServer inside a java service container framework, which makes it easy to deploy and monitor within our infrastructure. When upgrading to kafka 0.8 from 0.7.2, I ran into an issue with not being able to pass the needed constructor arg (SystemTime), since there doesn't appear to be an easy way to instantiate that from java. So, I ended up with this janky solution using SystemTime$.MODULE$.
> Could a default constructor be added which assumes a default SystemTime, rather than requiring that here?
> Note, I need to construct a KafkaServer directly, since I need to manage the lifecycle more directly than can be done with KafkaServerStartable.
> {code}
> // Need to do janky scala MODULE$ dereferencing, in order to get a default value in ctor
> server = new kafka.server.KafkaServer(kafkaConfig, SystemTime$.MODULE$);
> server.startup();
> {code}
--
This message was sent by Atlassian JIRA
(v6.1#6144)