阅读ApachePulsar上的分区主题

axkjgtzd 于 2021-06-04 发布在 Kafka

关注(0)|答案(1)|浏览(386)

我尝试在pulsar和kafka之间选择一个事件源/cqrs场景，因此这类系统的一个非常重要的特性是重放来自某个时间点或偏移量的消息。
Kafka很简单，你只需要指出从什么点开始消费，或者只是从一个起点开始寻找。
但是pulsar的工作原理不同，除了用户界面，它还有另一个叫做read interface的界面，用于从一个起点读取消息，比如begging或id，但它不适用于分区主题。
我的问题是，我怎样才能从一个关于脉冲星的分区主题中阅读？既然read接口不适用于分区主题，我可以为使用者指定一个起点吗？
我正在nodejs客户机上测试这些特性，因此如果因此丢失了某些特性，请告诉我

apache-kafka node.js apache-pulsar cqrs event-sourcing

来源：https://stackoverflow.com/questions/62783577/reading-partitioned-topics-on-apache-pulsar

1条答案

按热度按时间

yvgpqqbh1#

如果需要从特定分区读取，请在设置使用者主题时使用以下命令：

.topic(yourTopicName-partition-N)

哪里 yourTopicName 是一个划分的主题 N 从中读取所需的分区。
在 node.js 格式，如果您想从分区1中读取：

const consumer = await client.subscribe({
  topic: 'mytopic-partition-1',
  subscription: 'my-subscription',
});

赞(0）回复(0）举报 2021-06-05

我来回答

阅读ApachePulsar上的分区主题

1条答案

相关问题

热门标签

最新问答