Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/22293#discussion_r214209091
--- Diff:
external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaMicroBatchSourceSuite.scala
---
@@ -652,62 +654,67 @@ abstract class KafkaMicroBatchSourceSuiteBase extends
KafkaSourceSuiteBase {
}
}
+ val topicPartition = new TopicPartition(topic, 0)
// The message values are the same as their offsets to make the test
easy to follow
testUtils.withTranscationalProducer { producer =>
testStream(mapped)(
StartStream(ProcessingTime(100), clock),
waitUntilBatchProcessed,
CheckAnswer(),
- WithOffsetSync(topic) { () =>
+ WithOffsetSync(topicPartition) { () =>
--- End diff --
Good suggestion!
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
