Function TestRequiredAcks

produce_test.go:12–42

(t *testing.T)

)

func TestRequiredAcks(t *testing.T) {
	for _, acks := range []RequiredAcks{
		RequireNone,
		RequireOne,
		RequireAll,
	} {
		t.Run(acks.String(), func(t *testing.T) {
			a := strconv.Itoa(int(acks))
			x := RequiredAcks(-2)
			y := RequiredAcks(-2)
			b, err := acks.MarshalText()
			if err != nil {
				t.Fatal(err)
			}

			if err := x.UnmarshalText([]byte(a)); err != nil {
				t.Fatal(err)
			}
			if err := y.UnmarshalText(b); err != nil {
				t.Fatal(err)
			}

			if x != acks {
				t.Errorf("required acks mismatch after marshal/unmarshal text: want=%s got=%s", acks, x)
			}
			if y != acks {
				t.Errorf("required acks mismatch after marshal/unmarshal value: want=%s got=%s", acks, y)
			}
		})
	}
}

func TestClientProduce(t *testing.T) {
	client, topic, shutdown := newLocalClientAndTopic()