Namespace Org.Apache.Kafka.Connect.Source
Classes
- SourceRecord
SourceRecord are generated by KNetSourceTask<TTask> and passed to Kafka Connect for storage in Kafka. In addition to the standard fields in ConnectRecord<R, TKey, TValue> which specify where data is stored in Kafka, they also include a sourcePartition and sourceOffset.
- SourceRecord<TKey, TValue>
SourceRecord<TKey, TValue> are generated by KNetSourceTask<TTask> and passed to Kafka Connect for storage in Kafka. In addition to the standard fields in ConnectRecord<R, TKey, TValue> which specify where data is stored in Kafka, they also include a sourcePartition and sourceOffset.
- SourceRecord<TKeySource, TOffset, TKey, TValue>
SourceRecord<TKey, TValue> are generated by KNetSourceTask<TTask> and passed to Kafka Connect for storage in Kafka. In addition to the standard fields in ConnectRecord<R, TKey, TValue> which specify where data is stored in Kafka, they also include a sourcePartition and sourceOffset.
Interfaces
- ISourceConnectorContext
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/connect-api/4.0.0/org/apache/kafka/connect/source/SourceConnectorContext.html
- ISourceTaskContext
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/connect-api/4.0.0/org/apache/kafka/connect/source/SourceTaskContext.html
- ITransactionContext
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/connect-api/4.0.0/org/apache/kafka/connect/source/TransactionContext.html