Skip to content

Commit 2a6c3e7

Browse files
authored
Update reader example to README.md (#278)
Signed-off-by: xiaolong.ran <[email protected]>
1 parent 4712db1 commit 2a6c3e7

File tree

1 file changed

+30
-0
lines changed

1 file changed

+30
-0
lines changed

README.md

+30
Original file line numberDiff line numberDiff line change
@@ -103,6 +103,36 @@ fmt.Printf("Received message msgId: %#v -- content: '%s'\n",
103103

104104
```
105105

106+
Create a Reader:
107+
108+
```go
109+
client, err := pulsar.NewClient(pulsar.ClientOptions{URL: "pulsar://localhost:6650"})
110+
if err != nil {
111+
log.Fatal(err)
112+
}
113+
114+
defer client.Close()
115+
116+
reader, err := client.CreateReader(pulsar.ReaderOptions{
117+
Topic: "topic-1",
118+
StartMessageID: pulsar.EarliestMessageID(),
119+
})
120+
if err != nil {
121+
log.Fatal(err)
122+
}
123+
defer reader.Close()
124+
125+
for reader.HasNext() {
126+
msg, err := reader.Next(context.Background())
127+
if err != nil {
128+
log.Fatal(err)
129+
}
130+
131+
fmt.Printf("Received message msgId: %#v -- content: '%s'\n",
132+
msg.ID(), string(msg.Payload()))
133+
}
134+
```
135+
106136
## Contributing
107137

108138
Contributions are welcomed and greatly appreciated. See [CONTRIBUTING.md](CONTRIBUTING.md) for details on submitting patches and the contribution workflow.

0 commit comments

Comments
 (0)