Используя Kafka Streams, я могу отслеживать отставание с помощью JMX consumer-fetch-manager-metrics...

Наше приложение использует springBootVersion = 2.0.4.RELEASE вместе с compile('io

Я пытаюсь использовать Akka Kafka Streams, следуя документации Akka Kafka Streams .Вот код, который...

Проблема Когда я перезапускаю / завершаю / останавливаю поток, старый потребитель не умирает /...