Чем на рабочем проекте заменяли Kafka

В зависимости от требований к производительности и масштабируемости, Kafka можно заменить альтернативными брокерами сообщений:

1. RabbitMQ – для менее нагрузочных систем, где важна простота и гибкость маршрутизации сообщений.
   java

   Копировать

   ConnectionFactory factory = new ConnectionFactory();
   factory.setHost("localhost");
   try (Connection connection = factory.newConnection()) {
       Channel channel = connection.createChannel();
       channel.queueDeclare("my_queue", false, false, false, null);
       channel.basicPublish("", "my_queue", null, "Hello RabbitMQ!".getBytes());
   }

2. Apache Pulsar – если нужны мультитенантность, сегментированное хранение и низкая задержка.

3. AWS SQS/SNS или Google Pub/Sub – для облачных решений с managed-сервисом.

4. NATS – для ultra-low latency и простых use cases.

Выбор зависит от SLA, throughput, задержек и требований к отказоустойчивости. Kafka обычно заменяют при избыточной сложности для задачи.