KafkaSource<TOutput>

Class KafkaSource<TOutput>

A data flow source for Apache Kafka.

Inherited Members
Namespace: ETLBox.Apache.Kafka
Assembly: ETLBox.Apache.Kafka.dll
Syntax
    public class KafkaSource<TOutput> : DataFlowExecutableSource<TOutput>, IDataFlowExecutableSource<TOutput>, IDataFlowSource<TOutput>, IDataFlowExecutableSource, IDataFlowSource, IDataFlowComponent, ILoggableTask
Type Parameters
NameDescription
TOutput

Type of outgoing data.

Constructors

KafkaSource()

Declaration
    public KafkaSource()

Properties

BuilderContext

Declaration
    public Action<ConsumerBuilder<Ignore, TOutput>> BuilderContext { get; set; }
Property Value
TypeDescription
Action<ConsumerBuilder<Ignore, TOutput>>

ConsumerConfig

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

ConsumerContext

Declaration
    public Action<IConsumer<Ignore, TOutput>> ConsumerContext { get; set; }
Property Value
TypeDescription
Action<IConsumer<Ignore, TOutput>>

TimeOut

If no records can be consumed within this time span, the source will stop reading and send the completed signal to subsequent components.

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

TopicName

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

Methods

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

OnExecutionDoAsyncWork()

Declaration
    protected override void OnExecutionDoAsyncWork()
Overrides

Implements