diff --git a/pkg/writers/adapters/elasticsearch_test.go b/pkg/writers/adapters/elasticsearch_test.go index 5b32e42..73d214c 100644 --- a/pkg/writers/adapters/elasticsearch_test.go +++ b/pkg/writers/adapters/elasticsearch_test.go @@ -57,7 +57,7 @@ func TestAdapterReceiveInvalidMessage(t *testing.T) { bulk.AssertNotCalled(t, "func1") assert.Len(t, acks, 1) - assert.False(t, acks[0].Body[0] != 0) + assert.True(t, acks[0].Body[0] == 0) } func TestBulkActionWithErrorsMustDiscardAllMessages(t *testing.T) {