Package io.deephaven.kafka

Interface KafkaTools.StreamConsumerRegistrarProvider

All Known Implementing Classes:

KafkaTools.StreamConsumerRegistrarProvider.PerPartition, KafkaTools.StreamConsumerRegistrarProvider.Single

Enclosing class:

KafkaTools

public static interface KafkaTools.StreamConsumerRegistrarProvider

Marker interface for StreamConsumer registrar provider objects.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	KafkaTools.StreamConsumerRegistrarProvider.PerPartition
static class	KafkaTools.StreamConsumerRegistrarProvider.Single
static interface	KafkaTools.StreamConsumerRegistrarProvider.Visitor<T>

Method Summary

Modifier and Type	Method	Description
static KafkaTools.StreamConsumerRegistrarProvider.PerPartition	perPartition(@NotNull KafkaTools.PerPartitionConsumerRegistrar registrar)
static KafkaTools.StreamConsumerRegistrarProvider.Single	single(@NotNull KafkaTools.SingleConsumerRegistrar registrar)
<T> T	walk(KafkaTools.StreamConsumerRegistrarProvider.Visitor<T> visitor)

Method Details

single

static KafkaTools.StreamConsumerRegistrarProvider.Single single(@NotNull
 @NotNull KafkaTools.SingleConsumerRegistrar registrar)

Parameters:

registrar - The internal registrar method for StreamConsumer instances

Returns:

A StreamConsumerRegistrarProvider that registers a single consumer for all selected partitions

perPartition

static KafkaTools.StreamConsumerRegistrarProvider.PerPartition perPartition(@NotNull
 @NotNull KafkaTools.PerPartitionConsumerRegistrar registrar)

Parameters:

registrar - The internal registrar method for StreamConsumer instances

Returns:

A StreamConsumerRegistrarProvider that registers a new consumer for each selected partition

walk

<T> T walk(KafkaTools.StreamConsumerRegistrarProvider.Visitor<T> visitor)