[hotfix][connectors/kafka] Correctly check required configs in KafkaS…

…ourceBuilder
derekm · Mar 10, 2021 · eee76cd · eee76cd
1 parent 19bc493
commit eee76cd
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/...ector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java b/...ector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java
@@ -462,10 +462,8 @@ private void sanityCheck() {
  // Check required configs.
  for (String requiredConfig : REQUIRED_CONFIGS) {
  checkNotNull(
- props.getProperty(
- requiredConfig,
- String.format(
- "Property %s is required but not provided", requiredConfig)));
+ props.getProperty(requiredConfig),
+ String.format("Property %s is required but not provided", requiredConfig));
  }
  // Check required settings.
  checkNotNull(