kkonstantine commented on a change in pull request #9172:
URL: https://github.com/apache/kafka/pull/9172#discussion_r469578195
##########
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/integration/TransformationIntegrationTest.java
##########
@@ -318,4 +323,61 @@ public void testFilterOnHasHeaderKeyWithSourceConnector()
throws Exception {
// delete connector
connect.deleteConnector(CONNECTOR_NAME);
}
+
+ /**
+ * Test the {@link Filter} transformer with a
+ * {@link HasHeaderKey} predicate on a source connector.
+ */
+ @Test
+ public void testFilterOnHasHeaderKeyWithSourceConnectorAndTopicCreation()
throws Exception {
Review comment:
Since we have a few other tests replacing should be fine.
I'll add comments. But also, the test will fail if we don't create it (I
removed the admin command) because we disable auto topic creation at the
broker.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
