How to use confluent kafka producer InitTransactions

2021-09-12 Thread Thanuja Bhavani
Hi team, I have used kafka producer InitTransactions in my project, but I got a timeout error. Error: producer InitTransactions {"PID": 6041, "Service": "main", "error": "Failed to initialize Producer ID: Local: Timed out"} Here how I have created a producer object. p, err := confluentkafka.Ne

How to use confluent kafka producer InitTransactions

2021-09-10 Thread Thanuja Bhavani
Hi team, I have used kafka producer InitTransactions in my project, but I got timeout error. Error: producer InitTransactions {"PID": 6041, "Service": "main", "error": "Failed to initialize Producer ID: Local: Timed out"} Here how I have created a producer object. p, err := confluentkafka.NewP