Подписка api отдыха на события kafka

Question

Я недавно начал работать над Kafka для моего проекта.

Я пытаюсь выяснить, как я могу подписать API отдыха на событие Kafka вместо того, чтобы запускать потребителя, который продолжает слушать тему.

Я натолкнулся на Kafka connect, но не смог точно выяснить, как этого добиться.

Подробности: я запускаю подпружиненный проект в качестве производителя, который использует KafkaTemplate, предоставленныйвесной опубликовать сообщение.Также потребителем является проект Spring Boot, который предоставляет остальные API.

Answer 1

Нет другого способа, кроме как использовать потребительскую библиотеку Kafka для получения данных от Kafka.Kafka Connect сделает то же самое.

Служба RESTful не имеет состояния.Наличие потребителя является более динамичным (например, компенсация обслуживания).

Если вы хотите потоковые события в общем, возможно, вы могли бы вместо этого заглянуть в WebSockets или gRPC.