Pulsar Reader 例子
2019-12-19 19:28
706 查看
使用 reader 接口, Pulsar客户可以在主题中“手动定位”自己,从指定的消息开始向前读取所有消息
下面是一个示例:
import org.apache.pulsar.client.api.Message; import org.apache.pulsar.client.api.MessageId; import org.apache.pulsar.client.api.PulsarClient; import org.apache.pulsar.client.api.Reader; import org.apache.pulsar.client.impl.schema.JSONSchema; public class ReaderTest{ public static void main(String[] args) { String url = "http://192.168.1.48:8080"; try{ PulsarClient client =PulsarClient.builder() .serviceUrl(url) .build(); Reader<UserModel> reader=client.newReader(JSONSchema.of(UserModel.class)) .topic("my-tenant/my-namespace/testschema-topic") .startMessageId(MessageId.earliest) //MessageId.earliest最早 MessageId.latest 最新 MessageId断点 .create(); while (true) { Message<UserModel> userModelmsg = reader.readNext(); UserModel userModel=userModelmsg.getValue();//业务数据 MessageId messageId=userModelmsg.getMessageId();//断点 System.out.println("receive message: " +userModel.getName()+"="+userModel.getAge()+"="+messageId.toString()); } }catch(Exception e){ e.printStackTrace(); } } }
相关文章推荐
- 例子:RSS Reader Sample
- 收录的 SqlDataReader,ExecuteNonQuery ,ExecuteScalar,DataSet 例子
- [Struts2官方指南的个人学习和翻译] Struts2自带例子MailReader的学习
- Python CSV Reader/Writer 例子--转载
- 扩展ExtJS的【Ext.data.reader.Json】例子
- struts2自带例子mailreader学习(一)
- Python CSV Reader/Writer/DictReader/DictWriter例子
- XmlSerializer.Deserialize 方法 (XmlReader)的C#例子
- 灵活组装Json的数据使用Gson的JsonParser和JsonReader解析Json详解例子
- java bufferreader 例子代码
- 灵活组装Json的数据使用Gson的JsonParser和JsonReader解析Json详解例子
- SqlDataReader对象使用例子
- 灵活组装Json的数据使用Gson的JsonParser和JsonReader解析Json详解例子
- FileReader和FileWriter结合复制文本文件简单例子-2种方式(第二种效率比第一种高)
- 简单理解TensorFlow textlinereader的例子
- BufferReader和BufferWriter简单用法例子与结合实现复制文本文件简单例子
- Python CSV Reader/Writer/DictReader/DictWriter例子
- java StringReader使用例子代码
- C# 使用SqlDataReader方式使用数据做查询的例子
- Python CSV Reader/Writer 例子