becketqin commented on a change in pull request #8535: [FLINK-11693] Add
KafkaSerializationSchema that uses ProducerRecord
URL: https://github.com/apache/flink/pull/8535#discussion_r296672013
##########
File path:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java
##########
@@ -1217,6 +1219,99 @@ public void flatMap(Tuple3<Integer, Integer, String>
value, Collector<Integer> o
}
}
+ /**
+ * Test producing and consuming into multiple topics.
+ * @throws Exception
+ */
+ public void runProduceConsumeMultipleTopicsWithKafkaSerializer() throws
Exception {
Review comment:
I was thinking of using something like `instanceOf`. Given it is private
method, we don't need to worry much about the wrong argument type. We may need
to add some comments to explain that. Admittedly, this is not ideal, but
personally I feel it is slightly better than having a lot of duplicate code.
----------------------------------------------------------------
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:
[email protected]
With regards,
Apache Git Services
