Function TestProduceResponseEncode

produce_response_test.go:172–196

(t *testing.T)

}

func TestProduceResponseEncode(t *testing.T) {
	response := ProduceResponse{}
	response.Blocks = make(map[string]map[int32]*ProduceResponseBlock)
	testEncodable(t, "empty", &response, produceResponseNoBlocksV0)

	batchIndexErrMsg := "bad rec"
	errMsg := "bad batch"
	response.Blocks["foo"] = make(map[int32]*ProduceResponseBlock)
	response.Blocks["foo"][1] = &ProduceResponseBlock{
		Err:         ErrInvalidMessage,
		Offset:      255,
		Timestamp:   time.Unix(1, 0),
		StartOffset: 50,
		RecordErrors: []ProduceResponseRecordError{{
			BatchIndex:             3,
			BatchIndexErrorMessage: &batchIndexErrMsg,
		}},
		ErrorMessage: &errMsg,
	}
	response.ThrottleTime = 100 * time.Millisecond
	for v, produceResponseManyBlocks := range produceResponseManyBlocksVersions {
		response.Version = int16(v)
		testEncodable(t, fmt.Sprintf("many blocks version %d", v), &response, produceResponseManyBlocks)
	}
}

func TestProduceResponseEncodeInvalidTimestamp(t *testing.T) {
	response := ProduceResponse{}