com.github.hackerwin7.jlib.utils.drivers.kafka.data

Class TopicInfo

java.lang.Object

com.github.hackerwin7.jlib.utils.drivers.kafka.data.TopicInfo

public class TopicInfo
extends Object

Created by IntelliJ IDEA. User: hackerwin7 Date: 2015/12/16 Time: 2:01 PM Desc: kafka machine information

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TopicInfo.KafkaInfoBuilder

Method Summary

Modifier and Type	Method and Description
static TopicInfo.KafkaInfoBuilder	createBuilder()
Map<Integer,Long>	getBeginOffsetsMap()
Map<Integer,String>	getBrokerMap()
String	getBrokers()
String	getBrokers(int partition)
long	getEndOffsets(int partition)
Map<Integer,Long>	getEndOffsetsMap()
long	getoffset(int partition)
int	getPartitionNum()
String	getTopic()
String	getZks()
void	putBeginoffsetsAll(Map<Integer,Long> map)
void	putBrokersAll(Map<Integer,String> map)
void	putEndOffset(int partition, long endOffset)
void	putEndOffsetsAll(Map<Integer,Long> map)
void	putOffset(int partition, long offset)
void	putPartitionBroker(int partition, String brokers)
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

createBuilder

public static TopicInfo.KafkaInfoBuilder createBuilder()

getBrokers

public String getBrokers()

getZks

public String getZks()

getTopic

public String getTopic()

getPartitionNum

public int getPartitionNum()

putOffset

public void putOffset(int partition,
                      long offset)

putEndOffset

public void putEndOffset(int partition,
                         long endOffset)

getoffset

public long getoffset(int partition)

getEndOffsets

public long getEndOffsets(int partition)

getBeginOffsetsMap

public Map<Integer,Long> getBeginOffsetsMap()

getEndOffsetsMap

public Map<Integer,Long> getEndOffsetsMap()

putPartitionBroker

public void putPartitionBroker(int partition,
                               String brokers)

getBrokers

public String getBrokers(int partition)

getBrokerMap

public Map<Integer,String> getBrokerMap()

putBeginoffsetsAll

public void putBeginoffsetsAll(Map<Integer,Long> map)

putEndOffsetsAll

public void putEndOffsetsAll(Map<Integer,Long> map)

putBrokersAll

public void putBrokersAll(Map<Integer,String> map)

toString

public String toString()

Overrides:

toString in class Object