У меня есть потребитель RabbiMQ, который принимает сообщения по одному за раз. И мне нужно отправить эти сообщения в тему Kafka (используя confluent-kafka-dotnet). Как я могу сделать это надежно и не слишком медленно? Обратите внимание, что мне нужно вернуть acknoledge продюсеру Rabbit.
Если я отправлю сообщения с использованием Flush на каждом из них, это будет очень медленно. Но если я создам кучу сообщений и использую Flush в этой куче, я рискну пропустить сообщения в случае сбоя. Так какая стратегия лучше в этом случае.
постскриптум Мы решили постепенно перейти от кролика к кафке ...
p.p.s извините за мой плохой английский