This is an automated email from the ASF dual-hosted git repository.

riemer pushed a change to branch 
3483-use-kraft-based-kafka-as-default-for-internal-messaging
in repository https://gitbox.apache.org/repos/asf/streampipes.git


    from 2a5f0bdba9 feat(#3483): Use Kraft-based Kafka as default for internal 
messaging
     add 71776d9350 Let Kafka consumer wait until rebalancing is finished

No new revisions were added by this update.

Summary of changes:
 .../connectors/kafka/adapter/KafkaProtocol.java    |   8 +-
 .../messaging/kafka/SpKafkaConsumer.java           | 111 +++++++++++----------
 2 files changed, 60 insertions(+), 59 deletions(-)

Reply via email to