🐛 Source Kafka : fixed SASL config read issue (#8865)

airbytehq · Dec 21, 2021 · 67df5b8 · 67df5b8
1 parent 287cdb5
commit 67df5b8
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 4 deletions.
diff --git a/airbyte-config/init/src/main/resources/seed/source_definitions.yaml b/airbyte-config/init/src/main/resources/seed/source_definitions.yaml
@@ -329,7 +329,7 @@
 - name: Kafka
   sourceDefinitionId: d917a47b-8537-4d0d-8c10-36a9928d4265
   dockerRepository: airbyte/source-kafka
-  dockerImageTag: 0.1.1
+  dockerImageTag: 0.1.2
   documentationUrl: https://docs.airbyte.io/integrations/sources/kafka
   icon: kafka.svg
   sourceType: database

diff --git a/airbyte-integrations/connectors/source-kafka/Dockerfile b/airbyte-integrations/connectors/source-kafka/Dockerfile
@@ -9,4 +9,4 @@ COPY build/distributions/${APPLICATION}*.tar ${APPLICATION}.tar
 RUN tar xf ${APPLICATION}.tar --strip-components=1
 
 LABEL io.airbyte.name=airbyte/source-kafka
-LABEL io.airbyte.version=0.1.1
+LABEL io.airbyte.version=0.1.2
diff --git a/...rs/source-kafka/src/main/java/io/airbyte/integrations/source/kafka/KafkaSourceConfig.java b/...rs/source-kafka/src/main/java/io/airbyte/integrations/source/kafka/KafkaSourceConfig.java
@@ -86,8 +86,8 @@ private Map<String, Object> propertiesByProtocol(final JsonNode config) {
     switch (protocol) {
       case PLAINTEXT -> {}
       case SASL_SSL, SASL_PLAINTEXT -> {
-        builder.put(SaslConfigs.SASL_JAAS_CONFIG, config.get("sasl_jaas_config").asText());
-        builder.put(SaslConfigs.SASL_MECHANISM, config.get("sasl_mechanism").asText());
+        builder.put(SaslConfigs.SASL_JAAS_CONFIG, protocolConfig.get("sasl_jaas_config").asText());
+        builder.put(SaslConfigs.SASL_MECHANISM, protocolConfig.get("sasl_mechanism").asText());
       }
       default -> throw new RuntimeException("Unexpected Kafka protocol: " + Jsons.serialize(protocol));
     }

diff --git a/docs/integrations/sources/kafka.md b/docs/integrations/sources/kafka.md
@@ -73,4 +73,5 @@ More info about this can be found in the [Kafka consumer configs documentation s
 
 | Version | Date       | Pull Request                                           | Subject                                   |
 | :------ | :--------  | :------------------------------------------------------| :---------------------------------------- |
+| 0.1.2   | 2021-12-21 | [8865](https://github.com/airbytehq/airbyte/pull/8865) | Fix SASL config read issue                |
 | 0.1.1   | 2021-12-06 | [8524](https://github.com/airbytehq/airbyte/pull/8524) | Update connector fields title/description |