在脉冲星中如何通过按键获取信息

我的情况是，我在Pulsar (https://pulsar.apache.org/docs/en/concepts-topic-compaction/)中压缩了主题。通过producer，我使用key发送消息。是否可以通过对consumer使用key来获取特定的消息？

我的代码：

Producer<byte[]> producer = client.newProducer()
            .topic(TOPIC_NAME)
            .compressionType(CompressionType.LZ4).create();

    String name = "name";
    String lastName = "lastname";

    byte[] nameBytes = name.getBytes();
    byte[] lastNameBytes = lastName.getBytes();

    producer.newMessage().key("key1").value(nameBytes).send();
    producer.newMessage().key("key2").value(lastNameBytes).send();

    Consumer<byte[]> consumer = client.newConsumer()
            .topic(TOPIC_NAME)
            .readCompacted(true)
            .subscriptionName("test")
            .subscribe();

    // need to get message by key

转载请注明出处:http://www.jubohx.com/article/20230520/2481260.html