Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-20848

Kafka consumer ID is not specified correctly in new KafkaSource

    XMLWordPrintableJSON

    Details

      Description

      In the constructor of KafkaPartitionSplitReadersubtaskId should be assigned before invoking createConsumerClientId method because this method uses subtask ID as Kafka consumer ID's suffix

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                renqs Qingsheng Ren
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: