Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CustomEndpointSink ¶
func CustomEndpointSink[T, R any](stream runtime.TypedSinkStream[T, R], dataConsumer localsink.DataConsumer[T]) runtime.SinkConsumer[T]
func SaramaKafkaEndpointSink ¶ added in v0.0.186
func SaramaKafkaEndpointSink[T, R any](stream runtime.TypedSinkStream[T, R], partitioner kafka.Partitioner[T]) runtime.SinkConsumer[T]
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.