Есть ли способ в Java Spring boot, где я могу использовать одну очередь kafka для другого Java объекта?

Question

Я хочу использовать одну очередь kafka для разных Java объектов. Как мне этого добиться?

PS: Один из способов - преобразовать JavaObject в строку JSON и, получив его, преобразовать его в требуемый объект, и, если эта операция преобразования завершится неудачно, мы можем обработать ее изящно. Но я думаю, что это не очень хорошее решение.

Answer 1

Вы можете добавить заголовок к сообщению kafka при отправке сообщения и, основываясь на значении заголовка, вы можете привести его к желаемому объекту при получении.