Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-1962

KafkaSystemAdmin should accept custom configuration from user

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Open
    • Major
    • Resolution: Unresolved
    • None
    • None
    • None
    • None

    Description

      Currently KafkaSystemAdmin instantiates kafka.admin.AdminClient with only the bootstrap server url and the zookeeper url from user. As a result KafkaSystemAdmin can not talk to SSL port of broker.

      We need KafkaSystemAdmin to accept custom configuration specified by user such as those ssl related configs so that KafkaSystemAdmin can work in Kafka cluster that accepts only SSL-based connection.

      Attachments

        Activity

          People

            Unassigned Unassigned
            lindong Dong Lin
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: