Мы использовали map-Reduce (только период карты) для чтения из файла HDFS и публикации sh данных в Kafka. Чтобы оценить, сколько сообщений отправлено в Kafka, мы установили счетчик для этого. Пока номер не совпал с потребляемым сообщением. Потому что в обычном случае счетчик уменьшения карты включает только счетчики в карту успеха. Итак, перейдите к моему вопросу, как я могу накапливать счетчики как на карте успеха, так и на карте неудачи? Затем он должен соответствовать номеру сообщения, полученному от Kafka.