Исключение с истекшим сроком действия, когда размер пакета равен 0

#apache-kafka #kafka-producer-api

#apache-kafka #kafka-producer-api

Вопрос:

В какой ситуации вы можете получить ошибку org.apache.kafka.common.errors.TimeoutException: Batch Expired при попытке отправить сообщение с производителем Kafka, когда batch.size=0 ? Я не понимаю, как, если я не отправляю свои сообщения, я могу получить ошибку истечения срока действия пакета. Или просто в «пакете» содержится только одно сообщение, и срок действия этого сообщения истек до его отправки?

Комментарии:

1. похоже, ваш сервер kafka не работает.