You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2016/01/29 17:52:53 UTC
kafka git commit: KAFKA-3075;
Fix ClassCastException in `ZookeeperConsumerConnector.commitOffsets`
Repository: kafka
Updated Branches:
refs/heads/trunk 3cfa6da6f -> 20afdcdd2
KAFKA-3075; Fix ClassCastException in `ZookeeperConsumerConnector.commitOffsets`
Author: Ismael Juma <is...@juma.me.uk>
Reviewers: Guozhang Wang
Closes #833 from ijuma/kafka-3075-javaapi-consumer-class-cast-exception
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/20afdcdd
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/20afdcdd
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/20afdcdd
Branch: refs/heads/trunk
Commit: 20afdcdd2ec129e94cbf335555c3d78f19a2d58e
Parents: 3cfa6da
Author: Ismael Juma <is...@juma.me.uk>
Authored: Fri Jan 29 08:52:50 2016 -0800
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Fri Jan 29 08:52:50 2016 -0800
----------------------------------------------------------------------
.../scala/kafka/javaapi/consumer/ZookeeperConsumerConnector.scala | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/20afdcdd/core/src/main/scala/kafka/javaapi/consumer/ZookeeperConsumerConnector.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/javaapi/consumer/ZookeeperConsumerConnector.scala b/core/src/main/scala/kafka/javaapi/consumer/ZookeeperConsumerConnector.scala
index bfd8d37..6347bfd 100644
--- a/core/src/main/scala/kafka/javaapi/consumer/ZookeeperConsumerConnector.scala
+++ b/core/src/main/scala/kafka/javaapi/consumer/ZookeeperConsumerConnector.scala
@@ -21,6 +21,7 @@ import kafka.consumer._
import kafka.common.{OffsetAndMetadata, TopicAndPartition, MessageStreamsExistException}
import scala.collection.{immutable, mutable, JavaConversions}
import java.util.concurrent.atomic.AtomicBoolean
+import scala.collection.JavaConverters._
/**
* This class handles the consumers interaction with zookeeper
@@ -115,7 +116,7 @@ private[kafka] class ZookeeperConsumerConnector(val config: ConsumerConfig,
}
def commitOffsets(offsetsToCommit: java.util.Map[TopicAndPartition, OffsetAndMetadata], retryOnFailure: Boolean) {
- underlying.commitOffsets(offsetsToCommit.asInstanceOf[immutable.Map[TopicAndPartition, OffsetAndMetadata]], retryOnFailure)
+ underlying.commitOffsets(offsetsToCommit.asScala.toMap, retryOnFailure)
}
def setConsumerRebalanceListener(consumerRebalanceListener: ConsumerRebalanceListener) {