Title here
Summary here
A data flow destination for MongoDb.
public class KafkaDestination<TInput> : DataFlowBatchDestination<TInput>, IDataFlowLogging, IDataFlowBatchDestination<TInput>, IDataFlowDestination<TInput>, IDataFlowBatchDestination, IDataFlowDestination, IDataFlowComponent, ILoggableTask
Name | Description |
---|---|
TInput | Type of ingoing data. |
public KafkaDestination()
public KafkaDestination(int batchSize)
Type | Name | Description |
---|---|---|
int | batchSize |
public Action<ProducerBuilder<Null, TInput>> BuilderContext { get; set; }
Type | Description |
---|---|
Action<ProducerBuilder<Null, TInput>> |
public Action<DeliveryReport<Null, TInput>> DeliveryHandler { get; set; }
Type | Description |
---|---|
Action<DeliveryReport<Null, TInput>> |
public TimeSpan InitTransactionTimeout { get; set; }
Type | Description |
---|---|
TimeSpan |
public ProducerConfig ProducerConfig { get; set; }
Type | Description |
---|---|
ProducerConfig |
public Action<IProducer<Null, TInput>> ProducerContext { get; set; }
Type | Description |
---|---|
Action<IProducer<Null, TInput>> |
public string TopicName { get; set; }
Type | Description |
---|---|
string |
public bool UseTransaction { get; set; }
Type | Description |
---|---|
bool |
protected override void BulkInsertData(TInput[] data)
Type | Name | Description |
---|---|---|
TInput[] | data |
protected override void CheckParameter()
protected override void CleanUpOnFaulted(Exception e)
Type | Name | Description |
---|---|---|
Exception | e |
protected override void CleanUpOnSuccess()
protected override void FinishWrite()
protected override void PrepareWrite()