MCPcopy
hub / github.com/segmentio/kafka-go / TestListOffsetsResponse

Function TestListOffsetsResponse

protocol/listoffsets/listoffsets_test.go:54–104  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

52}
53
54func TestListOffsetsResponse(t *testing.T) {
55 prototest.TestResponse(t, v1, &listoffsets.Response{
56 Topics: []listoffsets.ResponseTopic{
57 {
58 Topic: "topic-1",
59 Partitions: []listoffsets.ResponsePartition{
60 {
61 Partition: 0,
62 ErrorCode: 0,
63 Timestamp: 1e9,
64 Offset: 1234567890,
65 },
66 },
67 },
68 },
69 })
70
71 prototest.TestResponse(t, v4, &listoffsets.Response{
72 ThrottleTimeMs: 1234,
73 Topics: []listoffsets.ResponseTopic{
74 {
75 Topic: "topic-1",
76 Partitions: []listoffsets.ResponsePartition{
77 {
78 Partition: 0,
79 ErrorCode: 0,
80 Timestamp: 1e9,
81 Offset: 1234567890,
82 LeaderEpoch: 10,
83 },
84 },
85 },
86 {
87 Topic: "topic-2",
88 Partitions: []listoffsets.ResponsePartition{
89 {
90 Partition: 0,
91 ErrorCode: 0,
92 Timestamp: 1e9,
93 Offset: 1234567890,
94 LeaderEpoch: 10,
95 },
96 {
97 Partition: 1,
98 ErrorCode: 2,
99 },
100 },
101 },
102 },
103 })
104}

Callers

nothing calls this directly

Calls 1

TestResponseFunction · 0.92

Tested by

no test coverage detected