KafkaDestination<TInput>

Class KafkaDestination<TInput>

A data flow destination for MongoDb.

Inherited Members
Namespace: ETLBox.Apache.Kafka
Assembly: ETLBox.Apache.Kafka.dll
Syntax
    public class KafkaDestination<TInput> : DataFlowBatchDestination<TInput>, IDataFlowBatchDestination<TInput>, IDataFlowDestination<TInput>, IDataFlowBatchDestination, IDataFlowDestination, IDataFlowComponent, ILoggableTask
Type Parameters
NameDescription
TInput

Type of ingoing data.

Constructors

KafkaDestination()

Declaration
    public KafkaDestination()

KafkaDestination(int)

Declaration
    public KafkaDestination(int batchSize)
Parameters
TypeNameDescription
intbatchSize

Properties

BuilderContext

Declaration
    public Action<ProducerBuilder<Null, TInput>> BuilderContext { get; set; }
Property Value
TypeDescription
Action<ProducerBuilder<Null, TInput>>

DeliveryHandler

Declaration
    public Action<DeliveryReport<Null, TInput>> DeliveryHandler { get; set; }
Property Value
TypeDescription
Action<DeliveryReport<Null, TInput>>

InitTransactionTimeout

Declaration
    public TimeSpan InitTransactionTimeout { get; set; }
Property Value
TypeDescription
TimeSpan

ProducerConfig

Declaration
    public ProducerConfig ProducerConfig { get; set; }
Property Value
TypeDescription
ProducerConfig

ProducerContext

Declaration
    public Action<IProducer<Null, TInput>> ProducerContext { get; set; }
Property Value
TypeDescription
Action<IProducer<Null, TInput>>

TopicName

Declaration
    public string TopicName { get; set; }
Property Value
TypeDescription
string

UseTransaction

Declaration
    public bool UseTransaction { get; set; }
Property Value
TypeDescription
bool

Methods

BulkInsertData(TInput[])

Declaration
    protected override void BulkInsertData(TInput[] data)
Parameters
TypeNameDescription
TInput[]data
Overrides

CheckParameter()

Declaration
    protected override void CheckParameter()
Overrides

CleanUpOnFaulted(Exception)

Declaration
    protected override void CleanUpOnFaulted(Exception e)
Parameters
TypeNameDescription
Exceptione
Overrides

CleanUpOnSuccess()

Declaration
    protected override void CleanUpOnSuccess()
Overrides

FinishWrite()

Declaration
    protected override void FinishWrite()
Overrides

PrepareWrite()

Declaration
    protected override void PrepareWrite()
Overrides

Implements