Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-14246 Update threading model for Consumer
  3. KAFKA-15180

Generalize integration tests to change use of KafkaConsumer to Consumer

    XMLWordPrintableJSON

Details

    Description

      For the consumer threading refactor project, we're introducing a new implementation of the Consumer interface. However, most of the instances in the integration tests specifically use the concrete implementation KafkaConsumer. This task is to generalize those uses where possible to use the Consumer interface.

      Attachments

        Issue Links

          Activity

            People

              kirktrue Kirk True
              kirktrue Kirk True
              Divij Vaidya Divij Vaidya
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: