Package io.deephaven.kafka

Interface KafkaTools.PerPartitionConsumerRegistrar

Enclosing class:

KafkaTools

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public static interface KafkaTools.PerPartitionConsumerRegistrar

Method Summary

Modifier and Type	Method	Description
void	register(@NotNull TableDefinition tableDefinition, @NotNull org.apache.kafka.common.TopicPartition topicPartition, @NotNull StreamPublisher streamPublisher)	Provide a per-partition StreamConsumer to streamPublisher via its register method.

Method Details

register

void register(@NotNull
 @NotNull TableDefinition tableDefinition,
 @NotNull
 @NotNull org.apache.kafka.common.TopicPartition topicPartition,
 @NotNull
 @NotNull StreamPublisher streamPublisher)

Provide a per-partition StreamConsumer to streamPublisher via its register method.

Parameters:

tableDefinition - The TableDefinition for the stream to be consumed

topicPartition - The TopicPartition to be consumed

streamPublisher - The StreamPublisher to register a StreamConsumer for