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