diff --git a/core/src/main/scala/kafka/javaapi/TopicMetadata.scala b/core/src/main/scala/kafka/javaapi/TopicMetadata.scala index d08c3f4..f384e04 100644 --- a/core/src/main/scala/kafka/javaapi/TopicMetadata.scala +++ b/core/src/main/scala/kafka/javaapi/TopicMetadata.scala @@ -44,6 +44,8 @@ class TopicMetadata(private val underlying: kafka.api.TopicMetadata) { def errorCode: Short = underlying.errorCode def sizeInBytes: Int = underlying.sizeInBytes + + override def toString = underlying.toString } @@ -68,5 +70,6 @@ class PartitionMetadata(private val underlying: kafka.api.PartitionMetadata) { def errorCode: Short = underlying.errorCode def sizeInBytes: Int = underlying.sizeInBytes -} + override def toString = underlying.toString +} diff --git a/core/src/main/scala/kafka/javaapi/TopicMetadataResponse.scala b/core/src/main/scala/kafka/javaapi/TopicMetadataResponse.scala index 252a0c9..3359060 100644 --- a/core/src/main/scala/kafka/javaapi/TopicMetadataResponse.scala +++ b/core/src/main/scala/kafka/javaapi/TopicMetadataResponse.scala @@ -23,4 +23,15 @@ class TopicMetadataResponse(private val underlying: kafka.api.TopicMetadataRespo import kafka.javaapi.MetadataListImplicits._ underlying.topicsMetadata } + + override def equals(other: Any) = canEqual(other) && { + val otherTopicMetadataResponse = other.asInstanceOf[kafka.javaapi.TopicMetadataResponse] + this.underlying.equals(otherTopicMetadataResponse.underlying) + } + + def canEqual(other: Any) = other.isInstanceOf[kafka.javaapi.TopicMetadataResponse] + + override def hashCode = underlying.hashCode + + override def toString = underlying.toString }