MCPcopy
hub / github.com/IBM/sarama / TestAddOffsetsToTxnResponse

Function TestAddOffsetsToTxnResponse

add_offsets_to_txn_response_test.go:15–22  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

13}
14
15func TestAddOffsetsToTxnResponse(t *testing.T) {
16 resp := &AddOffsetsToTxnResponse{
17 ThrottleTime: 100 * time.Millisecond,
18 Err: ErrInvalidProducerEpoch,
19 }
20
21 testResponse(t, "", resp, addOffsetsToTxnResponse)
22}

Callers

nothing calls this directly

Calls 1

testResponseFunction · 0.85

Tested by

no test coverage detected