-
- Downloads
[SPARK-13569][STREAMING][KAFKA] pattern based topic subscription
## What changes were proposed in this pull request? Allow for kafka topic subscriptions based on a regex pattern. ## How was this patch tested? Unit tests, manual tests Author: cody koeninger <cody@koeninger.org> Closes #14026 from koeninger/SPARK-13569.
Showing
- external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/ConsumerStrategy.scala 172 additions, 6 deletions...rg/apache/spark/streaming/kafka010/ConsumerStrategy.scala
- external/kafka-0-10/src/test/java/org/apache/spark/streaming/kafka010/JavaConsumerStrategySuite.java 15 additions, 0 deletions...e/spark/streaming/kafka010/JavaConsumerStrategySuite.java
- external/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/DirectKafkaStreamSuite.scala 71 additions, 3 deletions...che/spark/streaming/kafka010/DirectKafkaStreamSuite.scala
Loading
Please register or sign in to comment