This is an automated email from the ASF dual-hosted git repository.
rxl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git
The following commit(s) were added to refs/heads/master by this push:
new 2a6c3e7 Update reader example to README.md (#278)
2a6c3e7 is described below
commit 2a6c3e70fe5f445714d47d9e4b404b8dae853ae4
Author: 冉小龙 <[email protected]>
AuthorDate: Thu Jun 11 20:28:36 2020 +0800
Update reader example to README.md (#278)
Signed-off-by: xiaolong.ran <[email protected]>
---
README.md | 30 ++++++++++++++++++++++++++++++
1 file changed, 30 insertions(+)
diff --git a/README.md b/README.md
index acc96f1..17537eb 100644
--- a/README.md
+++ b/README.md
@@ -103,6 +103,36 @@ fmt.Printf("Received message msgId: %#v -- content:
'%s'\n",
```
+Create a Reader:
+
+```go
+client, err := pulsar.NewClient(pulsar.ClientOptions{URL:
"pulsar://localhost:6650"})
+if err != nil {
+ log.Fatal(err)
+}
+
+defer client.Close()
+
+reader, err := client.CreateReader(pulsar.ReaderOptions{
+ Topic: "topic-1",
+ StartMessageID: pulsar.EarliestMessageID(),
+})
+if err != nil {
+ log.Fatal(err)
+}
+defer reader.Close()
+
+for reader.HasNext() {
+ msg, err := reader.Next(context.Background())
+ if err != nil {
+ log.Fatal(err)
+ }
+
+ fmt.Printf("Received message msgId: %#v -- content: '%s'\n",
+ msg.ID(), string(msg.Payload()))
+}
+```
+
## Contributing
Contributions are welcomed and greatly appreciated. See
[CONTRIBUTING.md](CONTRIBUTING.md) for details on submitting patches and the
contribution workflow.
