public class KafkaDestination<TInput> : DataFlowBatchDestination<TInput>, IDataFlowBatchDestination<TInput>, IDataFlowDestination<TInput>, IDataFlowBatchDestination, IDataFlowDestination, IDataFlowComponent, ILoggableTask

    public KafkaDestination()

    public KafkaDestination(int batchSize)

    public Action<ProducerBuilder<Null, TInput>> BuilderContext { get; set; }

    public Action<DeliveryReport<Null, TInput>> DeliveryHandler { get; set; }

    public TimeSpan InitTransactionTimeout { get; set; }

    public ProducerConfig ProducerConfig { get; set; }

    public Action<IProducer<Null, TInput>> ProducerContext { get; set; }

    public string TopicName { get; set; }

    public bool UseTransaction { get; set; }

    protected override void BulkInsertData(TInput[] data)

    protected override void CheckParameter()

    protected override void CleanUpOnFaulted(Exception e)

    protected override void CleanUpOnSuccess()

    protected override void FinishWrite()

    protected override void PrepareWrite()