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