Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-4700

StreamsKafkaClient drops security configs

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Critical
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 0.10.2.0, 0.11.0.0
    • Component/s: None
    • Labels:
      None

      Description

      `StreamsKafkaClient` takes a `StreamsConfig` and calls `values` on it to create a `ChannelBuilder`. `values` creates a `Map` with parsed values for defined config names. `StreamsConfig` doesn't define security settings itself and hence the security configs are dropped.

      For `KafkaProducer` and `KafkaConsumer` used by Streams, there is some code that gets the original configs (using `originals` instead of `values`) and passes them to the `KafkaConsumer` and `KafkaProducer` constructors (both of which define the security configs).

      The suggested solution is to create a config definition for `StreamsKafkaClient` thas includes a copy of the `StreamsConfig` definition combined with the security configs definitions.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                ijuma Ismael Juma
                Reporter:
                ijuma Ismael Juma
                Reviewer:
                Guozhang Wang
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: