org.apache.storm.kafka.monitor

Class KafkaOffsetLagUtil

java.lang.Object

org.apache.storm.kafka.monitor.KafkaOffsetLagUtil

public class KafkaOffsetLagUtil
extends Object

Utility class for querying offset lag for kafka spout

Constructor Summary

Constructors

Constructor and Description
KafkaOffsetLagUtil()

Method Summary

Modifier and Type	Method and Description
static List<KafkaOffsetLagResult>	getOffsetLags(NewKafkaSpoutOffsetQuery newKafkaSpoutOffsetQuery)
static List<KafkaOffsetLagResult>	getOffsetLags(OldKafkaSpoutOffsetQuery oldKafkaSpoutOffsetQuery)
static void	main(String[] args)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaOffsetLagUtil

public KafkaOffsetLagUtil()

Method Detail

main

public static void main(String[] args)

getOffsetLags

public static List<KafkaOffsetLagResult> getOffsetLags(NewKafkaSpoutOffsetQuery newKafkaSpoutOffsetQuery)
                                                throws Exception

Parameters:

newKafkaSpoutOffsetQuery - represents the information needed to query kafka for log head and spout offsets

Returns:

log head offset, spout offset and lag for each partition

Throws:

Exception

getOffsetLags

public static List<KafkaOffsetLagResult> getOffsetLags(OldKafkaSpoutOffsetQuery oldKafkaSpoutOffsetQuery)
                                                throws Exception

Parameters:

oldKafkaSpoutOffsetQuery - represents the information needed to query kafka for log head and spout offsets

Returns:

log head offset, spout offset and lag for each partition

Throws:

Exception