Table of Contents

Namespace Org.Apache.Kafka.Streams

Classes

ClientInstanceIds

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/ClientInstanceIds.html

KafkaClientSupplier

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/KafkaClientSupplier.html

KafkaClientSupplierDirect

Direct override of KafkaClientSupplier or its generic type if there is one

KafkaStreams

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/KafkaStreams.html

KafkaStreams.CloseOptions

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/KafkaStreams.CloseOptions.html

KafkaStreams.State

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/KafkaStreams.State.html

KafkaStreams.StateListener

Listener for Kafka StateListener. Extends MASES.JCOBridge.C2JBridge.JVMBridgeListener, implements KafkaStreams.IStateListener

KafkaStreams.StateListenerDirect

Direct override of KafkaStreams.StateListener or its generic type if there is one

KeyQueryMetadata

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/KeyQueryMetadata.html

KeyValue

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/KeyValue.html

KeyValue<K, V>

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/KeyValue.html

LagInfo

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/LagInfo.html

StoreQueryParameters

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StoreQueryParameters.html

StoreQueryParameters<T>

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StoreQueryParameters.html

StreamsBuilder

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsBuilder.html

StreamsConfig

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.html

StreamsConfig.InternalConfig

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsConfig.InternalConfig.html

StreamsMetadata

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsMetadata.html

StreamsMetrics

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/StreamsMetrics.html

TaskMetadata

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/TaskMetadata.html

ThreadMetadata

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/ThreadMetadata.html

Topology

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/Topology.html

Topology.AutoOffsetReset

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/Topology.AutoOffsetReset.html

TopologyConfig

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/TopologyConfig.html

TopologyConfig.TaskConfig

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/TopologyConfig.TaskConfig.html

TopologyDescription

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/TopologyDescription.html

TopologyDescription.GlobalStore

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/TopologyDescription.GlobalStore.html

TopologyDescription.Node

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/TopologyDescription.Node.html

TopologyDescription.Processor

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/TopologyDescription.Processor.html

TopologyDescription.Sink

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/TopologyDescription.Sink.html

TopologyDescription.Source

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/TopologyDescription.Source.html

TopologyDescription.Subtopology

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/TopologyDescription.Subtopology.html

Interfaces

IClientInstanceIds

.NET interface for TO BE DEFINED FROM USER

IKafkaClientSupplier

.NET interface for org.mases.knet.generated.org.apache.kafka.streams.KafkaClientSupplier implementing https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.9.0/org/apache/kafka/streams/KafkaClientSupplier.html

IStreamsMetadata

.NET interface for TO BE DEFINED FROM USER

IStreamsMetrics

.NET interface for TO BE DEFINED FROM USER

ITaskMetadata

.NET interface for TO BE DEFINED FROM USER

IThreadMetadata

.NET interface for TO BE DEFINED FROM USER

ITopologyDescription

.NET interface for TO BE DEFINED FROM USER

KafkaStreams.IStateListener

.NET interface for KafkaStreams.StateListener