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

Function testConnJoinGroupInvalidGroupID

conn_test.go:773–778  ·  view source on GitHub ↗
(t *testing.T, conn *Conn)

Source from the content-addressed store, hash-verified

771}
772
773func testConnJoinGroupInvalidGroupID(t *testing.T, conn *Conn) {
774 _, err := conn.joinGroup(joinGroupRequest{})
775 if !errors.Is(err, InvalidGroupId) && !errors.Is(err, NotCoordinatorForGroup) {
776 t.Fatalf("expected %v or %v; got %v", InvalidGroupId, NotCoordinatorForGroup, err)
777 }
778}
779
780func testConnJoinGroupInvalidSessionTimeout(t *testing.T, conn *Conn) {
781 groupID := makeGroupID()

Callers

nothing calls this directly

Calls 1

joinGroupMethod · 0.65

Tested by

no test coverage detected