Title here
Summary here
A data flow source for Apache Kafka.
public class KafkaSource<TOutput> : DataFlowExecutableSource<TOutput>, IDataFlowExecutableSource<TOutput>, IDataFlowSource<TOutput>, IDataFlowExecutableSource, IDataFlowSource, IDataFlowComponent, ILoggableTask
Name | Description |
---|---|
TOutput | Type of outgoing data. |
public KafkaSource()
public Action<ConsumerBuilder<Ignore, TOutput>> BuilderContext { get; set; }
Type | Description |
---|---|
Action<ConsumerBuilder<Ignore, TOutput>> |
public ConsumerConfig ConsumerConfig { get; set; }
Type | Description |
---|---|
ConsumerConfig |
public Action<IConsumer<Ignore, TOutput>> ConsumerContext { get; set; }
Type | Description |
---|---|
Action<IConsumer<Ignore, TOutput>> |
If no records can be consumed within this time span, the source will stop reading and send the completed signal to subsequent components.
public TimeSpan TimeOut { get; set; }
Type | Description |
---|---|
TimeSpan |
public string TopicName { get; set; }
Type | Description |
---|---|
string |
protected override void CheckParameter()
protected override void CleanUpOnFaulted(Exception e)
Type | Name | Description |
---|---|---|
Exception | e |
protected override void CleanUpOnSuccess()
protected override void OnExecutionDoAsyncWork()