sarama/init_producer_id_response_test.go

package sarama

import (
	"testing"
	"time"
)

var (
	initProducerIDResponse = []byte{
		0, 0, 0, 100,
		0, 0,
		0, 0, 0, 0, 0, 0, 31, 64, // producerID = 8000
		0, 0, // epoch
	}

	initProducerIDRequestError = []byte{
		0, 0, 0, 100,
		0, 51,
		255, 255, 255, 255, 255, 255, 255, 255,
		0, 0,
	}
)

func TestInitProducerIDResponse(t *testing.T) {
	resp := &InitProducerIDResponse{
		ThrottleTime:  100 * time.Millisecond,
		ProducerID:    8000,
		ProducerEpoch: 0,
	}

	testResponse(t, "", resp, initProducerIDResponse)

	resp.Err = ErrConcurrentTransactions
	resp.ProducerID = -1

	testResponse(t, "with error", resp, initProducerIDRequestError)
}