@Internal public interface OffsetsInitializerValidator
OffsetsInitializer
with properties from KafkaSource
.Modifier and Type | Method and Description |
---|---|
void |
validate(Properties kafkaSourceProperties)
Validate offsets initializer with properties of Kafka source.
|
void validate(Properties kafkaSourceProperties) throws IllegalStateException
kafkaSourceProperties
- Properties of Kafka sourceIllegalStateException
- if validation failsCopyright © 2014–2023 The Apache Software Foundation. All rights reserved.