Package io.deephaven.kafka

Interface KafkaTools.SingleConsumerRegistrar

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.SingleConsumerRegistrar

Method Summary

Modifier and Type	Method	Description
void	register(@NotNull TableDefinition tableDefinition, @NotNull StreamPublisher streamPublisher)	Provide a single StreamConsumer to streamPublisher via its register method.

Method Details

register

void register(@NotNull
 @NotNull TableDefinition tableDefinition,
 @NotNull
 @NotNull StreamPublisher streamPublisher)

Provide a single StreamConsumer to streamPublisher via its register method.

Parameters:

tableDefinition - The TableDefinition for the stream to be consumed

streamPublisher - The StreamPublisher to register a StreamConsumer for