destination

Aug 7, 2024

Changes in this version

+ const ConfigAcks

+ const ConfigBatchBytes

+ const ConfigCaCert

+ const ConfigClientCert

+ const ConfigClientID

+ const ConfigClientKey

+ const ConfigCompression

+ const ConfigDeliveryTimeout

+ const ConfigInsecureSkipVerify

+ const ConfigSaslMechanism

+ const ConfigSaslPassword

+ const ConfigSaslUsername

+ const ConfigServers

+ const ConfigTlsEnabled

+ const ConfigTopic

Apr 25, 2024

Changes in this version

type Config

+ Topic string

+ func (c Config) ParseTopic() (topic string, f TopicFn, err error)

+ type TopicFn func(sdk.Record) (string, error)

Nov 9, 2023

Changes in this version

+ type Config struct

+ Acks string

+ BatchBytes int32

+ Compression string

+ DeliveryTimeout time.Duration

+ func (Config) Parameters() map[string]sdk.Parameter

+ func (c Config) CompressionCodecs() []kgo.CompressionCodec

+ func (c Config) RequiredAcks() kgo.Acks

+ func (c Config) Validate() error

+ func (c Config) WithKafkaConnectKeyFormat() Config

+ type FranzProducer struct

+ func NewFranzProducer(ctx context.Context, cfg Config) (*FranzProducer, error)

+ func (p *FranzProducer) Close(_ context.Context) error

+ func (p *FranzProducer) Produce(ctx context.Context, records []sdk.Record) (int, error)

+ type MockProducer struct

+ func NewMockProducer(ctrl *gomock.Controller) *MockProducer

+ func (m *MockProducer) Close(arg0 context.Context) error

+ func (m *MockProducer) EXPECT() *MockProducerMockRecorder

+ func (m *MockProducer) Produce(arg0 context.Context, arg1 []sdk.Record) (int, error)

+ type MockProducerMockRecorder struct

+ func (mr *MockProducerMockRecorder) Close(arg0 any) *gomock.Call

+ func (mr *MockProducerMockRecorder) Produce(arg0, arg1 any) *gomock.Call

+ type Producer interface

+ Close func(context.Context) error

+ Produce func(context.Context, []sdk.Record) (int, error)