[
https://issues.apache.org/jira/browse/KAFKA-1101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13803477#comment-13803477
]
Jason Rosenberg commented on KAFKA-1101:
----------------------------------------
Hi Joe,
I really don't need a java wrapper layer, as long as the signature for the
scala classes is readily accessible from java, which is usually the case.
Yeah, so what you suggest is all I need, just a single arg constructor: new
KafkaServer(kafkaConfig);
That was how it worked in 0.7.2. I'd guess that should be easy to expose, and
in that case have it default to using a default SystemTime (same as I end up
doing by passing SystemTime$.MODULE$).
Eventually, though, yes, it would be great to have a simple java wrapper api
library, that's well documented and fully interoperable with java.
Even the current kafka.javaapi.* package still requires using direct scala
classes (e.g. if you want to use a serializer for a producer, etc.).
For the most part though, the scala - java interop is great, so I can't
complain too much....
> 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)
