#apache-kafka #rabbitmq #apache-kafka-connect
Вопрос:
Я хочу использовать Kafka connect, чтобы читать события из темы Кафки и записывать их в RabbitMQ. Для этого мне нужно использовать раковину RabbitMQ.
Каждое из событий, поступающих от Кафки, должно быть отправлено в другую очередь (на основе некоторого поля в структуре событий), что означает, что должен использоваться другой ключ маршрутизации. Насколько я знаю, есть возможность настроить ключ статической маршрутизации в конфигурации приемника. Есть ли возможность настроить его динамически на основе событий для достижения требуемого поведения?
Комментарии:
1. Привет, что ты пробовал до сих пор?
2. @kissu Я просмотрел всю документацию Kafka connect и не нашел ничего, что отвечало бы моим потребностям. Я знаю, что есть возможность написать свой собственный коннектор, но я не хочу туда идти.
3. Я не знаком с кроличьим разъемом, но есть преобразование ValueToKey Connect, если это то, что вам нужно