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(-)