[camel-kafka-connector] 01/02: Fixed a minor issue in a test in SinkPojoToSchemaAndStructTransformTest

[valdar]

This is an automated email from the ASF dual-hosted git repository.

valdar pushed a commit to branch camel-kafka-connector-0.7.x
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit 17b59c51d01bb4d80f2002bb234e3faaf0b1a907
Author: Andrea Tarocchi <andrea.taroc...@gmail.com>
AuthorDate: Fri Jan 15 00:07:18 2021 +0100

    Fixed a minor issue in a test in SinkPojoToSchemaAndStructTransformTest
---
 .../transforms/SinkPojoToSchemaAndStructTransformTest.java             | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SinkPojoToSchemaAndStructTransformTest.java
 
b/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SinkPojoToSchemaAndStructTransformTest.java
index 5f1655a..4ac14ca 100644
--- 
a/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SinkPojoToSchemaAndStructTransformTest.java
+++ 
b/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SinkPojoToSchemaAndStructTransformTest.java
@@ -111,7 +111,8 @@ public class SinkPojoToSchemaAndStructTransformTest {
                 Schema.STRING_SCHEMA, "testKeyValue",
                 null, map);
 
-        sinkPojoToSchemaAndStructTransform.apply(cr);
+        ConnectRecord transformedCr = 
sinkPojoToSchemaAndStructTransform.apply(cr);
+        assertEquals(cr, transformedCr);
     }
 
     @Test()