Мы запускаем Kafka в производство и очень довольны этим. Одна из вещей, которую мы хотели бы сделать, - ввести задержку в процесс, чтобы проверить, как обрабатываются различные компоненты экосистемы, когда некоторая часть потока сообщений поступает позже, чем ожидалось.
Несмотря на то, что мы можем модифицировать компоненты так, чтобы вводить задержку, для нас было бы более идеальным иметь возможность оставить код как есть и внедрить задержку в сам процесс Kafka. Тем не менее, все в Кафке, похоже, ориентировано на устранение задержки.
Это невыполнимая цель или есть какой-то способ добавить задержку в процесс обмена сообщениями Kafka?