Потребитель Kafka не может получить сообщение, даже если он подписан на тему

Я подписываюсь на тему и пытаюсь получать сообщения, однако, хотя я вижу, что потребитель подписан на эту тему, я не получал сообщений с помощью consumer.consume(cts.token). код просто останавливается на этом.

Может ли быть этому причина?

0 ответов

Другие вопросы по тегам