Package org.opennms.core.ipc.sink.kafka.server.offset

Class KafkaOffset

java.lang.Object

org.opennms.core.ipc.sink.kafka.server.offset.KafkaOffset

All Implemented Interfaces:

Message

public class KafkaOffset
extends Object
implements Message

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(String consumerGroupName, String topic, int partition, long logSize, long consumerOffset, long lag)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object obj)
String	getConsumerGroupName()
long	getConsumerOffset()
long	getLag()
long	getLogSize()
int	getPartition()
String	getTopic()
int	hashCode()
void	setConsumerGroupName(String consumerGroupName)
void	setConsumerOffset(long consumerOffset)
void	setLag(long lag)
void	setLogSize(long logSize)
void	setPartition(int partition)
void	setTopic(String topic)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

KafkaOffset

public KafkaOffset()

KafkaOffset

public KafkaOffset(String consumerGroupName,
                   String topic,
                   int partition,
                   long logSize,
                   long consumerOffset,
                   long lag)

Method Detail

getConsumerGroupName

public String getConsumerGroupName()

setConsumerGroupName

public void setConsumerGroupName(String consumerGroupName)

getTopic

public String getTopic()

setTopic

public void setTopic(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 class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object