Class KafkaOffset
- java.lang.Object
-
- org.opennms.core.ipc.sink.kafka.server.offset.KafkaOffset
-
-
Field Summary
-
Fields inherited from interface org.opennms.core.ipc.sink.api.Message
SINK_METRIC_CONSUMER_DOMAIN, SINK_METRIC_PRODUCER_DOMAIN
-
-
Constructor Summary
Constructors Constructor Description KafkaOffset()
KafkaOffset(java.lang.String consumerGroupName, java.lang.String topic, int partition, long logSize, long consumerOffset, long lag)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(java.lang.Object obj)
java.lang.String
getConsumerGroupName()
long
getConsumerOffset()
long
getLag()
long
getLogSize()
int
getPartition()
java.lang.String
getTopic()
int
hashCode()
void
setConsumerGroupName(java.lang.String consumerGroupName)
void
setConsumerOffset(long consumerOffset)
void
setLag(long lag)
void
setLogSize(long logSize)
void
setPartition(int partition)
void
setTopic(java.lang.String topic)
java.lang.String
toString()
-
-
-
Method Detail
-
getConsumerGroupName
public java.lang.String getConsumerGroupName()
-
setConsumerGroupName
public void setConsumerGroupName(java.lang.String consumerGroupName)
-
getTopic
public java.lang.String getTopic()
-
setTopic
public void setTopic(java.lang.String topic)
-
getPartition
public int getPartition()
-
setPartition
public void setPartition(int partition)
-
getLogSize
public long getLogSize()
-
setLogSize
public void setLogSize(long logSize)
-
getConsumerOffset
public long getConsumerOffset()
-
setConsumerOffset
public void setConsumerOffset(long consumerOffset)
-
getLag
public long getLag()
-
setLag
public void setLag(long lag)
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object obj)
- Overrides:
equals
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-