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

Pass configuration though to Kafka encoder/decoder in KafkaSerdeFactory

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Minor
    • Resolution: Fixed
    • 0.9.0
    • 0.10.0
    • kafka
    • None
    • Any

    Description

      The KafkaSerdeFactory currently constructs Kafka encoders and decoders using the default constructor with no parameters. Kafka generally constructs these by passing in a VerifiableProperties to allow the constructor to configure them.

      I think we can do this by taking properties out of Samza's configuration map as with the kafka encoder/decoder setting then passing these through to the constructors.

      Attachments

        Activity

          People

            danharvey Dan Harvey
            danharvey Dan Harvey
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: