Пример десериализации весенней конфлюентной схемы
Кто-нибудь использовал spring-kafka 2.0.0.Release и создал потребителя, который использует реестр слитой схемы в качестве источника для десериализации сообщения? Если да, можете ли вы указать мне пример?
Проблема, которую я пытаюсь решить, заключается в том, что на моей платформе kafka connect у меня есть разъем Debezium CDC, который транслирует события из MongoDB по мере их возникновения. Я должен перехватить эти события преобразовать и повторно направить. Чтобы понять событие, мне нужно десериализовать полезную нагрузку. В данный момент я застрял на этом этапе.
1 ответ
Шастри
Эта проблема, похоже, решена некоторое время назад, поэтому я хотел бы указать следующий тест-код и конкретную часть в нем, где вы можете настроить схему-реестр kafka. Пожалуйста, посмотрите и убедитесь, что это ясно или вам нужна дополнительная помощь.