Interface StreamConfigProvider
- All Known Implementing Classes:
DefaultStreamConfigProvider,EmbeddedStreamConfigProvider
public interface StreamConfigProvider
-
Method Summary
Modifier and TypeMethodDescriptionscala.concurrent.Future<KafkaStreamSettings>getKafkaNotificationSettings(HRN hrn, InternalSettings internalSettings) scala.concurrent.Future<KafkaStreamSettings>getKafkaSettings(HRN hrn, String layerId, InternalSettings internalSettings)
-
Method Details
-
getKafkaNotificationSettings
scala.concurrent.Future<KafkaStreamSettings> getKafkaNotificationSettings(HRN hrn, InternalSettings internalSettings) -
getKafkaSettings
scala.concurrent.Future<KafkaStreamSettings> getKafkaSettings(HRN hrn, String layerId, InternalSettings internalSettings)
-