src/payload-processor/processor/processor_test.go


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

package processor

import (
	"testing"

	"github.com/segmentio/kafka-go"
	"github.com/stretchr/testify/require"
)

func TestProcessMessage(t *testing.T) {
	processor := Processor{}

	message := []byte("test")

	err := processor.handleMessage(kafka.Message{Value: message})

	require.NoError(t, err)
}