Packages

package services

Type Members

  1. case class HostStoreInfo(host: String, port: Int, storeNames: Set[String]) extends Product with Serializable
  2. class LocalStateStoreQuery[K, V] extends LazyLogging

    Abstraction that supports query from a local state store.

    Abstraction that supports query from a local state store. The query supports retry semantics if invoked during Kafka Streams' rebalancing act when states may migrate across stores.

  3. class MetadataService extends LazyLogging

    Looks up StreamsMetadata from KafkaStreams Adapted from https://github.com/confluentinc/kafka-streams-examples/blob/4.0.0-post/src/main/java/io/confluent/examples/streams/interactivequeries/MetadataService.java

Ungrouped