public class StateService extends Object implements AsyncBiFunctionService.WithSerdes<Void,Void,org.apache.kafka.streams.KafkaStreams.State>
AsyncBiFunctionService.WithSerdes<K,REQ,RES>
Constructor and Description |
---|
StateService(org.apache.kafka.streams.KafkaStreams streams) |
Modifier and Type | Method and Description |
---|---|
Stream<CompletionStage<org.apache.kafka.streams.KafkaStreams.State>> |
apply() |
CompletionStage<org.apache.kafka.streams.KafkaStreams.State> |
apply(Void v1,
Void v2) |
void |
close() |
org.apache.kafka.common.serialization.Serde<Void> |
keySerde() |
org.apache.kafka.common.serialization.Serde<Void> |
reqSerde() |
org.apache.kafka.common.serialization.Serde<org.apache.kafka.streams.KafkaStreams.State> |
resSerde() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
applyForStore
andThen
public static final String NAME
public void close()
close
in interface AutoCloseable
public org.apache.kafka.common.serialization.Serde<Void> keySerde()
keySerde
in interface AsyncBiFunctionService.WithSerdes<Void,Void,org.apache.kafka.streams.KafkaStreams.State>
public org.apache.kafka.common.serialization.Serde<Void> reqSerde()
reqSerde
in interface AsyncBiFunctionService.WithSerdes<Void,Void,org.apache.kafka.streams.KafkaStreams.State>
public org.apache.kafka.common.serialization.Serde<org.apache.kafka.streams.KafkaStreams.State> resSerde()
resSerde
in interface AsyncBiFunctionService.WithSerdes<Void,Void,org.apache.kafka.streams.KafkaStreams.State>
public Stream<CompletionStage<org.apache.kafka.streams.KafkaStreams.State>> apply()
apply
in interface AsyncBiFunctionService<Void,Void,org.apache.kafka.streams.KafkaStreams.State>
public CompletionStage<org.apache.kafka.streams.KafkaStreams.State> apply(Void v1, Void v2)
apply
in interface BiFunction<Void,Void,CompletionStage<org.apache.kafka.streams.KafkaStreams.State>>
Copyright © 2020 Red Hat. All rights reserved.