Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaSource ¶
func NewKafkaSource ¶
func NewKafkaSource(config *eventbusv1alpha1.KafkaBus, logger *zap.SugaredLogger) *KafkaSource
func (*KafkaSource) Connect ¶
func (s *KafkaSource) Connect(string) (eventbuscommon.EventSourceConnection, error)
func (*KafkaSource) Initialize ¶
func (s *KafkaSource) Initialize() error
type KafkaSourceConnection ¶
type KafkaSourceConnection struct { *base.KafkaConnection Topic string Client sarama.Client Producer sarama.SyncProducer }
func (*KafkaSourceConnection) Close ¶
func (c *KafkaSourceConnection) Close() error
func (*KafkaSourceConnection) IsClosed ¶
func (c *KafkaSourceConnection) IsClosed() bool
Click to show internal directories.
Click to hide internal directories.