Also I have to upgrade scalatest to 1.9 because 1.8 no longer exists.
However, I got a bunch of compile errors building with 2.10.2, any
insights will be much appreciated, thanks.
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/utils/Annota
tions.scala:31: not found: type StaticAnnotation
[error] class nonthreadsafe extends StaticAnnotation
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/api/FetchReq
uest.scala:166: type mismatch;
[error] found : kafka.utils.nonthreadsafe
[error] required: scala.annotation.Annotation
[error] @nonthreadsafe
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/utils/Pool.s
cala:74: value asSet is not a member of object
scala.collection.JavaConversions
[error] def keys = JavaConversions.asSet(pool.keySet())
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/utils/Annota
tions.scala:26: not found: type StaticAnnotation
[error] class threadsafe extends StaticAnnotation
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/consumer/Con
sumerTopicStats.scala:25: type mismatch;
[error] found : kafka.utils.threadsafe
[error] required: scala.annotation.Annotation
[error] @threadsafe
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/consumer/Sim
pleConsumer.scala:28: type mismatch;
[error] found : kafka.utils.threadsafe
[error] required: scala.annotation.Annotation
[error] @threadsafe
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/consumer/Zoo
keeperConsumerConnector.scala:443: value findIndexOf is not a member of
List[String]
[error] val myConsumerPosition = curConsumers.findIndexOf(_ ==
consumerThreadId)
[error] ^
[error] val currentChildren =
JavaConversions.asBuffer(children).toSet
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/javaapi/Fetc
hRequest.scala:32: value asMap is not a member of object
scala.collection.JavaConversions
[error] val scalaMap = JavaConversions.asMap(requestInfo).toMap
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/javaapi/Offs
etRequest.scala:31: value asMap is not a member of object
scala.collection.JavaConversions
[error] val scalaMap = JavaConversions.asMap(requestInfo).toMap
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/javaapi/Topi
cMetadata.scala:20: value asList is not a member of object
scala.collection.JavaConversions
[error] import scala.collection.JavaConversions.asList
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/javaapi/Topi
cMetadata.scala:25: not found: value asList
[error] asList(topicMetadataSeq.map(new
kafka.javaapi.TopicMetadata(_)))
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/javaapi/Topi
cMetadata.scala:29: not found: value asList
[error] asList(partitionMetadataSeq.map(new
kafka.javaapi.PartitionMetadata(_)))
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/javaapi/Topi
cMetadata.scala:54: not found: value asList
[error] def replicas: java.util.List[Broker] =
asList(underlying.replicas)
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/javaapi/Topi
cMetadata.scala:56: not found: value asList
[error] def isr: java.util.List[Broker] = asList(underlying.isr)
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/javaapi/Topi
cMetadataRequest.scala:30: value asBuffer is not a member of object
scala.collection.JavaConversions
[error] new kafka.api.TopicMetadataRequest(versionId, correlationId,
clientId, JavaConversions.asBuffer(topics))
[error]
^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/javaapi/cons
umer/SimpleConsumer.scala:28: type mismatch;
[error] found : kafka.utils.threadsafe
[error] required: scala.annotation.Annotation
[error] @threadsafe
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/javaapi/cons
umer/ZookeeperConsumerConnector.scala:21: value asList is not a member of
object scala.collection.JavaConversions
[error] import scala.collection.JavaConversions.asList
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/javaapi/cons
umer/ZookeeperConsumerConnector.scala:76: not found: value asMap
[error] val scalaTopicCountMap: Map[String, Int] = Map.empty[String,
Int] ++ asMap(topicCountMap.asInstanceOf[java.util.Map[String, Int]])
[error]
^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/javaapi/cons
umer/ZookeeperConsumerConnector.scala:92: not found: value asList
[error] asList(underlying.createMessageStreamsByFilter(topicFilter,
numStreams, keyDecoder, valueDecoder))
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/javaapi/mess
age/ByteBufferMessageSet.scala:28: value asBuffer is not a member of
object scala.collection.JavaConversions
[error] this(new kafka.message.ByteBufferMessageSet(compressionCodec,
new AtomicLong(0), scala.collection.JavaConversions.asBuffer(messages):
_*).buffer)
[error]
^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/javaapi/prod
ucer/Producer.scala:41: not found: value asBuffer
[error] underlying.send(asBuffer(messages):_*)
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/log/FileMess
ageSet.scala:36: type mismatch;
[error] found : kafka.utils.nonthreadsafe
[error] required: scala.annotation.Annotation
[error] @nonthreadsafe
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/log/Log.scal
a:100: type mismatch;
[error] found : kafka.utils.threadsafe
[error] required: scala.annotation.Annotation
[error] @threadsafe
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/log/LogManag
er.scala:38: type mismatch;
[error] found : kafka.utils.threadsafe
[error] required: scala.annotation.Annotation
[error] @threadsafe
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/log/LogSegme
nt.scala:32: type mismatch;
[error] found : kafka.utils.nonthreadsafe
[error] required: scala.annotation.Annotation
[error] @nonthreadsafe
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/network/Bloc
kingChannel.scala:34: type mismatch;
[error] found : kafka.utils.nonthreadsafe
[error] required: scala.annotation.Annotation
[error] @nonthreadsafe
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/network/Boun
dedByteBufferReceive.scala:28: type mismatch;
[error] found : kafka.utils.nonthreadsafe
[error] required: scala.annotation.Annotation
[error] @nonthreadsafe
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/network/Boun
dedByteBufferSend.scala:25: type mismatch;
[error] found : kafka.utils.nonthreadsafe
[error] required: scala.annotation.Annotation
[error] @nonthreadsafe
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/network/Byte
BufferSend.scala:24: type mismatch;
[error] found : kafka.utils.nonthreadsafe
[error] required: scala.annotation.Annotation
[error] @nonthreadsafe
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/producer/Pro
ducerTopicStats.scala:25: type mismatch;
[error] found : kafka.utils.threadsafe
[error] required: scala.annotation.Annotation
[error] @threadsafe
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/producer/Syn
cProducer.scala:33: type mismatch;
[error] found : kafka.utils.threadsafe
[error] required: scala.annotation.Annotation
[error] @threadsafe
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/server/Messa
geSetSend.scala:31: type mismatch;
[error] found : kafka.utils.nonthreadsafe
[error] required: scala.annotation.Annotation
[error] @nonthreadsafe
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/tools/JmxToo
l.scala:89: not found: value asSet
[error] val names = queries.map((name: ObjectName) =>
asSet(mbsc.queryNames(name, null))).flatten
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/utils/Annota
tions.scala:36: not found: type StaticAnnotation
[error] class immutable extends StaticAnnotation
[error] ^
[warn]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/utils/Json.s
cala:35: This catches all Throwables. If this is really intended, use
`case t : Throwable` to clear this warning.
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/utils/Pool.s
cala:77: value asIterable is not a member of object
scala.collection.JavaConversions
[error] JavaConversions.asIterable(new ArrayList[V](pool.values()))
[error] ^
[error]
/Users/rngu/ij/kafka-0.8.0-beta1-src/core/src/main/scala/kafka/utils/Thrott
ler.scala:36: type mismatch;
[error] found : kafka.utils.nonthreadsafe
[error] required: scala.annotation.Annotation
[error] @nonthreadsafe
[error] ^
[error] 37 errors found
On 10/30/13, 3:26 PM, "Ngu, Bob" <bob....@intel.com> wrote:
>Hi,
>
>I decided to start a new thread regarding Kafka 0.8 beta1 support for
>Scala 2.10.2 and OSGi. I asked about 2.10.2 in a different thread
>
>I am using Maven to build my Scala library but to resolve the bad POM
>definition issue, https://issues.apache.org/jira/browse/KAFKA-1064, I
>added all the required dependencies to my POM and thought I had to use
>Scala 2.9.2 but it seems to build just fine with 2.10.2, this should be
>fine, right?
>
>However, I am getting java.lang.NoClassDefFoundError:
>scala/reflect/ClassManifest error calling ProducerConfig
> val config = new ProducerConfig(props)
>
>I believe this is because Kafka is built with 2.9.2 so I made the
>following changes to Build.scala
> scalaVersion := ³2.10.2² ,
> publishTo := Some(Resolver.file("file", new
>File(Path.userHome.absolutePath+"/.m2/repository"))),
>
>I should be able to run ³sbt publish² to my local maven repository.
>However, I also need to package this library in OSGi format since I am
>using the library in OSGi, does anyone know if this works in OSGi? I
>would also need to include addSbtPlugin("com.typesafe.sbt" % "sbt-osgi" %
>"0.4.0²) for OSGi bundling.
>
>Thanks for any help!
>Bob
>
>
>
