in rocketmq-spark/src/main/scala/org/apache/rocketmq/spark/OffsetRange.scala [74:82]
override def equals(obj: Any): Boolean = obj match {
case that: OffsetRange =>
this.topic == that.topic &&
this.queueId == that.queueId &&
this.brokerName == that.brokerName &&
this.fromOffset == that.fromOffset &&
this.untilOffset == that.untilOffset
case _ => false
}