Hi Devs, does anybody if we have a JIRA to address the below warnings
that present themselves in the compileScala task in BrokerProxy?
If not I will create one.
/home/steve/samza-workspace/incubator-samza/samza-kafka/src/main/scala/org/apache/samza/system/kafka/BrokerProxy.scala:68: warning: trait ConcurrentMap in package mutable is deprecated: Use `scala.collection.concurrent.Map`
instead.
val nextOffsets:mutable.ConcurrentMap[TopicAndPartition, Long] =
new ConcurrentHashMap[TopicAndPartition, Long]()
^
/home/steve/samza-workspace/incubator-samza/samza-kafka/src/main/scala/org/apache/samza/system/kafka/BrokerProxy.scala:68: warning: method mapAsScalaDeprecatedConcurrentMap in trait LowPriorityWrapAsScala is deprecated: Use `mapAsScalaConcurrentMap` instead, and use `concurrent.Map` instead of
`ConcurrentMap`.
val nextOffsets:mutable.ConcurrentMap[TopicAndPartition, Long] =
new ConcurrentHashMap[TopicAndPartition, Long]()
^
/home/steve/samza-workspace/incubator-samza/samza-kafka/src/main/scala/org/apache/samza/system/kafka/BrokerProxy.scala:68: warning: trait ConcurrentMap in package mutable is deprecated: Use `scala.collection.concurrent.Map`
instead.
val nextOffsets:mutable.ConcurrentMap[TopicAndPartition, Long] =
new ConcurrentHashMap[TopicAndPartition, Long]()
^
/home/steve/samza-workspace/incubator-samza/samza-kafka/src/main/scala/org/apache/samza/system/kafka/BrokerProxy.scala:92: warning: method asJavaConcurrentMap in trait WrapAsJava is deprecated: Use `concurrent.Map` instead of
`ConcurrentMap`.
if (nextOffsets.containsKey(tp)) {
^
/home/steve/samza-workspace/incubator-samza/samza-kafka/src/main/scala/org/apache/samza/system/kafka/BrokerProxy.scala:114: warning: method asJavaConcurrentMap in trait WrapAsJava is deprecated: Use `concurrent.Map` instead of
`ConcurrentMap`.
if (nextOffsets.containsKey(tp)) {
Steve
