GlobalConsumerOffsetsRegistry (Azkarra Streams 0.7.0 API)

java.lang.Object
- io.streamthoughts.azkarra.api.streams.consumer.GlobalConsumerOffsetsRegistry

All Implemented Interfaces:: ConsumerGroupOffsetsRegistry

public final class GlobalConsumerOffsetsRegistry
extends Object
implements ConsumerGroupOffsetsRegistry

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`static GlobalConsumerOffsetsRegistry`	`getInstance()`
`ConsumerGroupOffsetsState`	`offsetsFor(String group)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getInstance

public static GlobalConsumerOffsetsRegistry getInstance()

offsetsFor
```
public ConsumerGroupOffsetsState offsetsFor(String group)
```
Specified by:

offsetsFor in interface ConsumerGroupOffsetsRegistry