Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Consumer ¶
type Consumer[Output pubsub.MessageTransformer[KafkaMessage, Output]] struct { // contains filtered or unexported fields }
func NewConsumer ¶
func NewConsumer[Output pubsub.MessageTransformer[KafkaMessage, Output]](kafka PubSub, topic string) *Consumer[Output]
NewConsumer create a consumer to take kafka message and send them to the destination.
Output object must implement the MessageTransformer interface from KafkaMessage to themselves
type KafkaMessage ¶
type KafkaMessage struct {
Topic string
Payload []byte
Headers []kgo.RecordHeader
Done chan error
}
type KafkaMessageFilter ¶
type KafkaMessageFilter struct {
Topic string
}
func (*KafkaMessageFilter) Filter ¶
func (k *KafkaMessageFilter) Filter(message KafkaMessage) bool
type PubSub ¶
type PubSub struct {
// contains filtered or unexported fields
}
func NewBlockingPubSub ¶
NewBlockingPubSub creates a new PubSub instance with blocking behavior
func (*PubSub) Unsubscribe ¶
func (k *PubSub) Unsubscribe(c <-chan KafkaMessage) error
Source Files
Click to show internal directories.
Click to hide internal directories.