Плохая новость: если это уже произошло, вы мало что можете сделать. Возможно, производитель сможет повторно обработать данные, но это сильно зависит от вашего приложения. Так что ... извините, я ничем не могу помочь. Вместо этого я постараюсь описать наиболее важную конфигурацию для предотвращения потери данных в Kafka. Обновление: следующий блог был написан для Kafka ‹2.8.0. KIP-679 изменяет конфигурацию производителя по умолчанию для подтверждения с 1 на все и для..

Предполагаемое знание В этом сообщении в блоге предполагается, что вы хорошо понимаете следующее (ссылки рядом с каждым, если вам нужно лучше понять) Python 3 https://www.python.org/doc/essays/blurb/ Nameko для Python https://www.nameko.io/ Кафка Python https://github.com/dpkp/kafka-python Кафка https://kafka.apache.org/ Если вы еще этого не сделали, то документация по всему вышеперечисленному великолепна и определенно стоит того, чтобы ее прочесть. Вступление Целью..

Привет, ребята! В этой статье я собираюсь обсудить, как сериализовать объекты с помощью сериализатора avro и реестра схем. Оглавление Настройте среду для Kafka (сервер Kafka, Zookeeper, Schema Registry) и Docker. Настроить среду программирования Создайте схему отправляемого объекта. Создайте производителя и отправьте в тему серийный объект Avro. Создайте клиента и используйте данные, опубликованные производителем. Создайте другого производителя и отправьте..

Как исправить это распространенное исключение В одной из моих предыдущих статей говорилось о тестировании приложений Kafka Streams. Вот совет, который может пригодиться! Во время тестирования вы можете встретить java.util.NoSuchElementException: Uninitialized topic исключение. Скорее всего, это связано с тем, что вы вызвали TestOutputTopic.readValue (например, как часть проверки assert ). Проблема не в самом исключении, а в сообщении об ошибке Uninitialized topic , которое..

Построение сквозного видеоконвейера машинного обучения Я всегда думал, что здорово потратить время на кодирование проекта с полным видеопотоком, на самом деле, когда я искал все классные приложения, я редко находил хорошо объясненное руководство, которое дало бы мне представление о том, как построить конвейер, который будет принимать видеопоток и делать его доступным для приложения для последующей обработки, такой как вариант использования для обнаружения лиц или классификации..