Поток Кафка - Двунаправленный

Question

Предположим, я хочу реализовать приложение, которое будет действовать как производитель и потребитель одновременно. Клиент должен иметь возможность подписаться на ряд тем и получать события. Он также должен иметь возможность ответить, когда он получает событие, не требуя, чтобы производитель подписался на тему. Это возможно? Что ты предлагаешь? Нужно ли для этого использовать поток Кафки?

Спасибо, Адиб

Answer 1

Это зависит от того, что именно вы хотите сделать. Как отмечает @WGSSAMINTHA, только потребители подписываются на темы. Производитель всегда может писать в любую тему (если не настроен ACL, ограничивающий доступ).

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

Также возможно использовать KafkaStreams. Преимущество KafkaStreams заключается в том, что он обеспечивает абстракцию более высокого уровня, предлагает встроенную обработку отказоустойчивого состояния и DSL высокого уровня. Он менее гибок, чем обычные KafkaConsumer и KafkaProducer, но может быть и менее эффективным для вас.

Это компромисс между гибкостью и удобством.

Answer 2

Только потребителю необходимо подписаться на тему, потому что потребитель всегда слушает тему и выбирает события.

Производители просто отправляют события в темы, и им не нужно слушать темы.