Simple example using Go timing out after 20 seconds

[hermanschaaf]

Hi, I am trying to write a simple GRPC consumer in Go. For a start, I thought I'd try and list the available topics with ListTopics. I was able to connect to port 19092 via curl and consume messages via that route, so I think kafka-pixy is set up correctly. But using Go and gRPC I get timeouts.

Here is the code I'm running:

package main

import (
    pb "github.com/mailgun/kafka-pixy/gen/golang"
    "google.golang.org/grpc"
    "time"
    "context"
    "log"
)

func main() {
    serverAddr := "127.0.0.1:19091"
    conn, err := grpc.Dial(serverAddr, grpc.WithInsecure())
    if err != nil {
        panic(err)
    }
    defer conn.Close()
    client := pb.NewKafkaPixyClient(conn)

    ctx, cancel := context.WithTimeout(context.Background(), 20*time.Second)
    defer cancel()

    tr := pb.ListTopicRq{}
    r, err := client.ListTopics(ctx, &tr)
    if err != nil {
        panic(err)
    }
    log.Println(r)
}

Unfortunately, it fails with:

panic: rpc error: code = DeadlineExceeded desc = context deadline exceeded

goroutine 1 [running]:
main.main()
    /Users/hermanschaaf/hermanschaaf/kafka-read-proxy/main.go:26 +0x279

Process finished with exit code 2

Does anyone know what I might be doing wrong here?

[horkhe]

I hate to say it, but it works for me. Are you following the steps outlined here? If it still does not work for you please provide kafka-pixy logs.

[horkhe]

I am closing this as not reproducible. Feel free to reopen if you have more information.