Я работаю над существующим проектом и использую kafka для получения некоторых данных из БД (для генерации отчетов). У меня есть несколько вопросов. Что может показаться глупым для многих (извините за это). Я упоминаю шаги, которые я выполнял до сих пор.
- Установлен Confluent
- Запущен Zookeeper, Kafka и Schema Registry
- Я скачал MySql коннекторов jars и скопировал в kafka-connect-jdb c
- Затем сделал mysql файл свойств с URL-адресом соединения, topi c -prefix et c.
Я запустил соединитель mysql с помощью этой команды bin / connect-standalone и т. Д. / Schema-registry / connect-avro-standalone.properties и т. Д. / Kafka-connect-jdbc / source-quickstart- mysql .properties
После этого, если я запускаю команду потребителя avro в терминале, используя эту команду bin / kafka-avro-console-consumer --topi c mysql -01 - bootstrap -сервер localhost: 9092 --из начала
он успешно выдает данные.
Теперь проблема и путаница. Я хочу получить те же данные с помощью Spring Boot. Я пишу код только для потребителя. Нужен ли мне продюсер здесь ?? (Согласно моему пониманию, у меня уже есть данные в моей топи c, мне просто нужно их получить) Я также разработал для этого схему avro. Он также десериализован, но я не получаю данные.
Данные, которые печатаются в терминале:
{"cust_code":27,"cust_description":{"string":"Endline survey completed"}}
Данные в консоли Spring Boot:
{"cust_code": "cust_description":{"string":""}}