Package org.apache.kafka.connect.source
Interface SourceTaskContext
-
public interface SourceTaskContext
SourceTaskContext is provided to SourceTasks to allow them to interact with the underlying runtime.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Map<String,String>
configs()
Get the Task configuration.OffsetStorageReader
offsetStorageReader()
Get the OffsetStorageReader for this SourceTask.
-
-
-
Method Detail
-
configs
Map<String,String> configs()
Get the Task configuration. This is the latest configuration and may differ from that passed on startup. For example, this method can be used to obtain the latest configuration if an external secret has changed, and the configuration is using variable references such as those compatible withConfigTransformer
.
-
offsetStorageReader
OffsetStorageReader offsetStorageReader()
Get the OffsetStorageReader for this SourceTask.
-
-