()
| 18 | ) |
| 19 | |
| 20 | func ExampleBroker() { |
| 21 | broker := NewBroker("localhost:9092") |
| 22 | err := broker.Open(nil) |
| 23 | if err != nil { |
| 24 | panic(err) |
| 25 | } |
| 26 | |
| 27 | request := MetadataRequest{Topics: []string{"myTopic"}} |
| 28 | response, err := broker.GetMetadata(&request) |
| 29 | if err != nil { |
| 30 | _ = broker.Close() |
| 31 | panic(err) |
| 32 | } |
| 33 | |
| 34 | fmt.Println("There are", len(response.Topics), "topics active in the cluster.") |
| 35 | |
| 36 | if err = broker.Close(); err != nil { |
| 37 | panic(err) |
| 38 | } |
| 39 | } |
| 40 | |
| 41 | type mockEncoder struct { |
| 42 | bytes []byte |
nothing calls this directly
no test coverage detected