(t *testing.T)
| 84 | } |
| 85 | |
| 86 | func TestNewOffsetManager(t *testing.T) { |
| 87 | seedBroker := NewMockBroker(t, 1) |
| 88 | metadataResponse := new(MetadataResponse) |
| 89 | metadataResponse.AddBroker(seedBroker.Addr(), seedBroker.BrokerID()) |
| 90 | seedBroker.Returns(metadataResponse) |
| 91 | findCoordResponse := new(FindCoordinatorResponse) |
| 92 | findCoordResponse.Coordinator = &Broker{id: seedBroker.brokerID, addr: seedBroker.Addr()} |
| 93 | seedBroker.Returns(findCoordResponse) |
| 94 | defer seedBroker.Close() |
| 95 | |
| 96 | testClient, err := NewClient([]string{seedBroker.Addr()}, NewTestConfig()) |
| 97 | if err != nil { |
| 98 | t.Fatal(err) |
| 99 | } |
| 100 | |
| 101 | om, err := NewOffsetManagerFromClient("group", testClient) |
| 102 | if err != nil { |
| 103 | t.Error(err) |
| 104 | } |
| 105 | safeClose(t, om) |
| 106 | safeClose(t, testClient) |
| 107 | |
| 108 | _, err = NewOffsetManagerFromClient("group", testClient) |
| 109 | if !errors.Is(err, ErrClosedClient) { |
| 110 | t.Errorf("Error expected for closed client; actual value: %v", err) |
| 111 | } |
| 112 | } |
| 113 | |
| 114 | // Test that the correct sequence of offset commit messages is sent to a broker when |
| 115 | // multiple goroutines for a group are committing offsets at the same time |
nothing calls this directly
no test coverage detected