package
1.3.2
Repository: https://github.com/numaproj/numaflow.git
Documentation: pkg.go.dev

# Functions

NewConsumerHandler creates new handler and initializes the channel for passing messages.
NewKafkaSource returns a kafkaSource reader based on Kafka Consumer Group.
WithBufferSize is used to return size of message channel information.
WithGroupName is used to set the group name.
WithReadTimeOut is used to set the read timeout for the from buffer.

# Structs

ConsumerHandler struct.

# Type aliases

No description provided by the author