[ 
https://issues.apache.org/jira/browse/KAFKA-1101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14728732#comment-14728732
 ] 

Dhaval M Patel commented on KAFKA-1101:
---------------------------------------

Has support for single constructor been added to apache kafka 0.8.2.1 jar?

> 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.3.4#6332)

Reply via email to