Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EnvAccessorCtor ¶
func EnvAccessorCtor() pkgadapter.EnvConfigAccessor
EnvAccessorCtor for configuration parameters
func NewTarget ¶
func NewTarget(ctx context.Context, envAcc pkgadapter.EnvConfigAccessor, ceClient cloudevents.Client) pkgadapter.Adapter
NewTarget adapter implementation
Types ¶
type KafkaAdminClient ¶
type KafkaAdminClient interface {
GetMetadata(topic *string, allTopics bool, timeoutMs int) (*kafka.Metadata, error)
CreateTopics(ctx context.Context, topics []kafka.TopicSpecification, options ...kafka.CreateTopicsAdminOption) (result []kafka.TopicResult, err error)
Close()
}
KafkaAdminClient is a wrapper of the Confluent Kafka admin functions needed for the Confluent adapter.
type KafkaClient ¶
type KafkaClient interface {
Produce(msg *kafka.Message, deliveryChan chan kafka.Event) error
CreateKafkaAdminClient() (KafkaAdminClient, error)
Flush(timeoutMs int) int
Close()
}
KafkaClient is a wrapper of the Confluent Kafka producer functions needed for the Confluent adapter.
func NewKafkaClient ¶
func NewKafkaClient(cfg *kafka.ConfigMap) (KafkaClient, error)
NewKafkaClient creates a Kafka client
Source Files
Click to show internal directories.
Click to hide internal directories.