Add all examples to example directory
This commit is contained in:
parent
61fa84eca6
commit
3b3b252fa5
13 changed files with 3 additions and 3 deletions
|
|
@ -343,7 +343,7 @@ func main() {
|
||||||
|
|
||||||
# Examples
|
# Examples
|
||||||
|
|
||||||
There are example Produder and Consumer code in `/cmd` directory. These should help give end-to-end examples of setting up consumers with different checkpoint strategies.
|
There are examples of producer and comsumer in the `/examples` directory. These should help give end-to-end examples of setting up consumers with different checkpoint strategies.
|
||||||
|
|
||||||
The examples run locally against [Kinesis Lite](https://github.com/mhart/kinesalite).
|
The examples run locally against [Kinesis Lite](https://github.com/mhart/kinesalite).
|
||||||
|
|
||||||
|
|
@ -351,11 +351,11 @@ The examples run locally against [Kinesis Lite](https://github.com/mhart/kinesal
|
||||||
|
|
||||||
Produce data to the stream:
|
Produce data to the stream:
|
||||||
|
|
||||||
$ cat cmd/producer/users.txt | go run cmd/producer/main.go --stream myStream
|
$ cat examples/producer/users.txt | go run examples/producer/main.go --stream myStream
|
||||||
|
|
||||||
Consume data from the stream:
|
Consume data from the stream:
|
||||||
|
|
||||||
$ go run cmd/consumer/main.go --stream myStream
|
$ go run examples/consumer/main.go --stream myStream
|
||||||
|
|
||||||
## Contributing
|
## Contributing
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue