Method RefreshTransactionCoordinator

client.go:109–109

RefreshTransactionCoordinator retrieves the coordinator for a transaction id and stores it in local cache. This function only works on Kafka 0.11.0.0 and higher.

(transactionID string)

	// RefreshTransactionCoordinator retrieves the coordinator for a transaction id and stores it
	// in local cache. This function only works on Kafka 0.11.0.0 and higher.
	RefreshTransactionCoordinator(transactionID string) error

	// InitProducerID retrieves information required for Idempotent Producer
	InitProducerID() (*InitProducerIDResponse, error)