Схема на стороне производителя:
{
"type":"record",
"name":"ClientIdentifier",
"namespace":"namespace1",
"fields":[
{
"name":"data",
"type":"string"
}
]
}
Схема на стороне потребителя:
{
"type":"record",
"name":"ClientIdentifier",
"namespace":"namespace2",
"fields":[
{
"name":"data",
"type":"string"
}
]
}
Оба имеют разные пространства имен. Как сделать их совместимыми друг с другом.
Я использую кодеры и декодеры, присутствующие в сгенерированных авроклассах, для сериализации и десериализации.
Также я использую аннотацию @KafkaListener для потребителя при весенней загрузке.