Class ConsumerClientOffsets
- java.lang.Object
-
- io.streamthoughts.azkarra.api.streams.consumer.ConsumerClientOffsets
-
public class ConsumerClientOffsets extends Object
-
-
Constructor Summary
Constructors Constructor Description ConsumerClientOffsets(String clientId, String streamThread, Set<ConsumerLogOffsets> offsets)
Creates a newConsumerClientOffsets
instance.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
clientId()
boolean
equals(Object o)
int
hashCode()
List<ConsumerLogOffsets>
positions()
String
streamThread()
String
toString()
void
update(ConsumerLogOffsets position)
-
-
-
Constructor Detail
-
ConsumerClientOffsets
public ConsumerClientOffsets(String clientId, String streamThread, Set<ConsumerLogOffsets> offsets)
Creates a newConsumerClientOffsets
instance.- Parameters:
clientId
- the current client-id attached to this topic-partition.streamThread
- the current stream-thread attached to this topic-partition.
-
-
Method Detail
-
clientId
public String clientId()
-
streamThread
public String streamThread()
-
positions
public List<ConsumerLogOffsets> positions()
-
update
public void update(ConsumerLogOffsets position)
-
-