Path Lines of Code broker.go 1297 client.go 965 offset_manager.go 479