Поиск ключа или значения в Kafka - PullRequest
1 голос
/ 03 августа 2020

Здравствуйте, у меня есть тема A в Kafka, и я сохранил сообщение с key =name и value=John. Есть ли способ запроса для указанного c значения или ключа?

1 Ответ

1 голос
/ 03 августа 2020

Нет, в Kafka это невозможно.

Kafka - это не хранилище значений ключей, а скорее журнал, предназначенный только для добавления. Он использует индекс под названием offset, который вы можете использовать для получения определенного сообщения. Однако смещение не связано с содержимым данных, и вам необходимо знать его заранее.

Альтернатива - использовать все сообщения в топи c, а затем отфильтровать то, которое вас интересует . Но это будет довольно неэффективно и, вероятно, не то, что вы искали.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...