Uploaded image for project: 'CDAP'
  1. CDAP
  2. CDAP-12549

Kafka source plugin should allow custom configurations for consumer

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 5.0.0
    • Component/s: Kafka, Pipeline Plugins
    • Labels:
    • Release Notes:
      Added support for specifying custom consumer configs in Kafka source
    • Rank:
      1|i007l3:

      Description

      Kafka source plugin should allow custom configurations for consumer.
      For instance, a user can not currently set 'max.partition.fetch.bytes' (among many other consumer properties) for the kafka consumer used by a kafka source pipeline.

      This should be for the batch and the realtime kafka source.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                yaojie Yaojie Feng
                Reporter:
                ali.anwar Ali Anwar
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: