Kafka обслуживает шину обмена сообщениями и гарантирует порядок сообщений.Это означает, что порядок, в котором вы зафиксировали сообщение в теме;Потребитель будет опрашивать сообщения в том же порядке.
Теперь в вашем случае вам нужно проверить
- , как производитель отправляет сообщения?
- как вы справляетесьсообщение повторяется?
- и проверять получателя в соответствии с предложением @Robin Moffatt