Я пытаюсь воспроизвести рабочий трафик на тестовом экземпляре Kafka с помощью MirrorMaker.
У меня есть пакетная работа, которая отстает от моих брокеров Kafka каждые 15 минут. Однако мой Kafka MirrorMaker периодически выходит из строя со следующим сообщением:
[2019-01-15 17: 34: 33,108] ОШИБКА Ошибка при отправке сообщения в тему
имя темы с ключом: 24 байта, значение: 824 байта с ошибкой:
(Org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
java.lang.IllegalStateException: источник принудительно закрыт. в
org.apache.kafka.clients.producer.internals.RecordAccumulator.abortBatches (RecordAccumulator.java:696)
в
org.apache.kafka.clients.producer.internals.RecordAccumulator.abortIncompleteBatches (RecordAccumulator.java:683)
в
org.apache.kafka.clients.producer.internals.Sender.run (Sender.java:185)
at java.lang.Thread.run (Thread.java:748)
Это проблема самого MirrorMaker или кода, который читает из кластера? Есть ли какие-то настройки, которые мне нужно установить в моих файлах конфигурации MirrorMaker, чтобы этого не происходило?