Package io.quarkus.smallrye.reactivemessaging.kafka

Class RedisStateStore

java.lang.Object
io.quarkus.smallrye.reactivemessaging.kafka.RedisStateStore
All Implemented Interfaces:
io.smallrye.reactive.messaging.kafka.commit.CheckpointStateStore
public class RedisStateStore extends Object implements io.smallrye.reactive.messaging.kafka.commit.CheckpointStateStore

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static class 
    RedisStateStore.Factory
     

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final String
    REDIS_STATE_STORE
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    RedisStateStore(io.quarkus.redis.datasource.ReactiveRedisDataSource redis, String consumerGroupId, io.smallrye.reactive.messaging.kafka.commit.ProcessingStateCodec stateCodec)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
     
    io.smallrye.mutiny.Uni<Map<org.apache.kafka.common.TopicPartition,io.smallrye.reactive.messaging.kafka.commit.ProcessingState<?>>>
    fetchProcessingState(Collection<org.apache.kafka.common.TopicPartition> partitions)
     
    io.smallrye.mutiny.Uni<Void>
    persistProcessingState(Map<org.apache.kafka.common.TopicPartition,io.smallrye.reactive.messaging.kafka.commit.ProcessingState<?>> states)
     

    Methods inherited from class java.lang.Object

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

  • Field Details

  • Constructor Details

    • RedisStateStore

      public RedisStateStore(io.quarkus.redis.datasource.ReactiveRedisDataSource redis, String consumerGroupId, io.smallrye.reactive.messaging.kafka.commit.ProcessingStateCodec stateCodec)

  • Method Details

    • close

      public void close()
      Specified by:
      close in interface io.smallrye.reactive.messaging.kafka.commit.CheckpointStateStore

    • fetchProcessingState

      public io.smallrye.mutiny.Uni<Map<org.apache.kafka.common.TopicPartition,io.smallrye.reactive.messaging.kafka.commit.ProcessingState<?>>> fetchProcessingState(Collection<org.apache.kafka.common.TopicPartition> partitions)
      Specified by:
      fetchProcessingState in interface io.smallrye.reactive.messaging.kafka.commit.CheckpointStateStore

    • persistProcessingState

      public io.smallrye.mutiny.Uni<Void> persistProcessingState(Map<org.apache.kafka.common.TopicPartition,io.smallrye.reactive.messaging.kafka.commit.ProcessingState<?>> states)
      Specified by:
      persistProcessingState in interface io.smallrye.reactive.messaging.kafka.commit.CheckpointStateStore