-
Notifications
You must be signed in to change notification settings - Fork 74
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
is there a tutorial document to teacher new how to use the api #120
Comments
what's the differences with sarama ? |
Hi @hy05190134, there's no tutorial at the moment, however you may take a look at https://github.com/stealthly/go_kafka_client/blob/master/consumers/consumers.go and https://github.com/stealthly/go_kafka_client/blob/master/mirror_maker.go to see how to run the consumer. You may also see tests https://github.com/stealthly/go_kafka_client/blob/master/consumer_test.go for reference as well. The main difference between go_kafka_client and sarama is that go_kafka_client implement a high-level consumer (https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example) whereas sarama doesn't. go_kafka_client now uses Zookeeper for coordination and committing offsets and in general is a high-level library that makes use of sarama to communicate with Kafka brokers. |
I have already read consumers.go, how can I see a new message in output when a new message product into kafka server? I use see it try to consume every specific time and no message to print in the terminal |
Its in the GetStrategy function in https://github.com/stealthly/go_kafka_client/blob/master/consumers/consumers.go |
No description provided.
The text was updated successfully, but these errors were encountered: