Кафка: как повторно использовать незафиксированное / не подтвержденное сообщение
Мы используем стратегию ручной фиксации. Мы настроили bean-компонент, который фиксирует все успешно использованные сообщения. Мы пытаемся добавить логику для повторного использования неподтвержденных сообщений. Мы сталкиваемся с проблемой, что одно и то же сообщение потребляется, но временной интервал для повторного использования неодинаков. Иногда восстанавливается быстро, но иногда занимает несколько часов.
Как мы можем убедиться, что незафиксированные сообщения будут обработаны в течение заданного времени.
Пользовательский скаляр GraphQL
Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...
Как вычислять биты и понимать побитовые операторы в Java - объяснение с примерами
В компьютерном программировании биты играют важнейшую роль в представлении и манипулировании данными на двоичном уровне. Побитовые операции...
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Приходилось ли вам сталкиваться с требованиями, в которых вас могли попросить поднять тревогу или выдать ошибку, когда метод Java занимает больше...
Полный курс Java для разработчиков веб-сайтов и приложений
Получите сертификат Java Web и Application Developer, используя наш курс.
0
1
388
1
Ответы 1
Вы можете выполнить операцию seek() над Consumer, чтобы сбросить его до определенного смещения.
Другие вопросы по теме
Запускать Confluent JDBC Connector в определенное время вместо использования интервала опроса?
Слишком много портов TCP в состоянии CLOSE WAIT в брокере kafka
Ошибка конфигурации карты для производителя kafka в файле свойств
Получить максимальное, минимальное смещение из кадра данных kafka
Может ли Kafka ProducerInterceptor фильтровать записи?
Механизм рабочего процесса для Apache Kafka?
Чтение только определенных сообщений из темы кафки
Бесконечный поток и массовая запись в базу данных
Как отделить потребителя от группы потребителей, не теряя взаимозачета?
SchemaException — ошибка при чтении поля «leader_id»: длина строки -1 не может быть отрицательной — концентраторы событий Azure — Kafka
Похожие вопросы
Javafx borderpane выравнивается по левому и правому краю
Java: как присвоить String ArrayList списку <Enum>
Как использовать свойства, извлеченные из @PropertySource
Как создать контейнер и загрузить данные только с помощью SAS с помощью AzureBlobStorage Java SDK v10
WatchKey всегда равен нулю
Как создать новую карту, разделив ключи карты <String, List<Object>>, которые содержат повторяющиеся имена
Получение java.lang.IncompatibleClassChangeError при выполнении теста
Несколько обновлений одного и того же объекта
Банкомат, использующий структуру данных, ищет массив данных класса клиента и сохраняет его в построителе строк
Напечатать некоторый разделитель для каждого скользящего окна в потоковых данных Flink
Ну, я не уверен, зачем вам повторно использовать сообщение или зачем вам нужно использовать неподтвержденное сообщение? Если брокер kafka настроен с ack=all или ack=leader, потребитель будет использовать только подтвержденные сообщения. Я хочу сказать, что, возможно, есть лучшее решение.