Apache Kafka. Потоковая обработка и анализ данных
Қосымшада ыңғайлырақҚосымшаны жүктеуге арналған QRRuStore · Samsung Galaxy Store
Huawei AppGallery · Xiaomi GetApps

автордың кітабынан сөз тіркестері  Apache Kafka. Потоковая обработка и анализ данных

Денис
Денисдәйексөз келтірді2 жыл бұрын
Брокеры Kafka ожидают, что в качестве ключей и значений сообщений задействуются байтовые массивы.
1 Ұнайды
Комментарий жазу
каждое ли сообщение критически важно, или потеря части сообщений допустима? Допустимо ли случайное дублирование сообщений? Нужно ли придерживаться каких-либо жестких требований относительно длительности задержки или пропускной способности?
Комментарий жазу
каждое ли сообщение критически важно, или потеря части сообщений допустима? Допустимо ли случайное дублирование сообщений? Нужно ли придерживаться каких-либо жестких требований относительно длительности задержки или пропускной способности?
Комментарий жазу
каждое ли сообщение критически важно, или потеря части сообщений допустима? Допустимо ли случайное дублирование сообщений? Нужно ли придерживаться каких-либо жестких требований относительно длительности задержки или пропускной способности?
Комментарий жазу
каждое ли сообщение критически важно, или потеря части сообщений допустима? Допустимо ли случайное дублирование сообщений? Нужно ли придерживаться каких-либо жестких требований относительно длительности задержки или пропускной способности?
Комментарий жазу
Елена Василенко
Елена Василенкодәйексөз келтірді5 күн бұрын
Начиная с Apache Kafka 2.1, мы разделяем время, затраченное на отправку ProduceRecord, на два временных интервала, которые обрабатываются отдельно. • Время до возвращения асинхронного вызова функции send(). В течение этого интервала поток, вызвавший функцию send(), будет заблокирован. • Время с момента успешного возврата асинхронного вы
Комментарий жазу
Елена Василенко
Елена Василенкодәйексөз келтірді5 күн бұрын
зова send() до запуска обратного вызова (успешного или с ошибкой). Это то же самое, что и с момента, когда запись ProduceRecord была помещена в пакет для отправки, до момента, когда Kafka ответит успехом, ошибкой, неустранимым отказом или закончится время, отведенное на отправку
Комментарий жазу
Елена Василенко
Елена Василенкодәйексөз келтірді6 күн бұрын
Не рекомендуется выполнять блокирующие операции внутри обратного вызова
Комментарий жазу
Елена Василенко
Елена Василенкодәйексөз келтірді6 күн бұрын
будут выполняться в том же порядке, в котором мы их отправили.
Комментарий жазу
Елена Василенко
Елена Василенкодәйексөз келтірді6 күн бұрын
Это гарантирует, что, когда мы отправляем два сообщения в один и тот же раздел одно за другим, их обратные вызовы
Комментарий жазу