Rename func

artie-labs · Nov 4, 2024 · 6c4f2d9 · 6c4f2d9
1 parent a9bec14
commit 6c4f2d9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/kafkalib/writer_test.go b/lib/kafkalib/writer_test.go
@@ -24,7 +24,7 @@ func TestNewMessage(t *testing.T) {
 		},
 	)
 
-	msg, err := newMessage("topic-prefix", rawMessage)
+	msg, err := buildKafkaMessage("topic-prefix", rawMessage)
 	assert.NoError(t, err)
 	assert.Equal(t, "topic-prefix.topic-suffix", msg.Topic)
 	assert.Equal(t, `{"key":"value"}`, string(msg.Key))