Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- func main() {
- config = sarama.NewConfig()
- config.ClientID = "go-kafka-consumer"
- config.Consumer.Return.Errors = true
- // Create new consumer
- master, err := sarama.NewConsumer("localhost:9092", config)
- if err != nil {
- panic(err)
- }
- defer func() {
- if err := master.Close(); err != nil {
- panic(err)
- }
- }()
- partitionConsumer, err := master.ConsumePartition("myTopic",0,
- sarama.OffsetOldest)
- if err != nil {
- panic(err)
- }
- }
- c := consumer.NewConsumer()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement