Я застрял в проблеме, когда моя kafka работает на другом экземпляре, а мое приложение на другом экземпляре, и они оба общаются с помощью kafka ksql, каждый раз, когда в очередь kafka поступает новая транзакция, и мое приложение, и kafka будутопросить ту же информацию и выполнить ее обработку, но проблема в том, что между моим приложением и kafka нет синхронизации, поэтому я не могу знать, для какой транзакции ksql дает мне результат, мне нужно какое-то событие, которое сообщит мнекак только ksql завершит свои вычисления, чтобы я мог синхронизировать свое приложение с ksql.
Другими словами, у меня должен быть какой-то способ узнать, когда Kafka SQL фиксирует смещение в своей теме в кластере, а затем,мое приложение получает сообщение из этой темы.
Это больше связано с проблемой медленного производителя и быстрого потребителя
Пожалуйста, дайте мне знать, если требуется какая-либо дополнительная информация.