add { in creation of ClientOptions
@@ -69,7 +69,7 @@ import (
)
func main() {
- client, err := pulsar.NewClient(pulsar.ClientOptions
+ client, err := pulsar.NewClient(pulsar.ClientOptions{
URL: "pulsar://localhost:6650",
OperationTimeoutSeconds: 5,
MessageListenerThreads: runtime.NumCPU(),
