public class KafkaSource<TOutput> : DataFlowExecutableSource<TOutput>, IDataFlowExecutableSource<TOutput>, IDataFlowSource<TOutput>, IDataFlowExecutableSource, IDataFlowSource, IDataFlowComponent, ILoggableTask

    public KafkaSource()

    public Action<ConsumerBuilder<Ignore, TOutput>> BuilderContext { get; set; }

    public ConsumerConfig ConsumerConfig { get; set; }

    public Action<IConsumer<Ignore, TOutput>> ConsumerContext { get; set; }

    public TimeSpan TimeOut { get; set; }

    public string TopicName { get; set; }

    protected override void CheckParameter()

    protected override void CleanUpOnFaulted(Exception e)

    protected override void CleanUpOnSuccess()

    protected override void OnExecutionDoAsyncWork()