subject:"\[GitHub\] \[pulsar\-adapters\] eolivelli commented on a change in pull request #31\: \[Issue #29\] \[pulsar\-spark\] Adding SparkPulsarReliableReceiver"

[GitHub] [pulsar-adapters] eolivelli commented on a change in pull request #31: [Issue #29] [pulsar-spark] Adding SparkPulsarReliableReceiver

2022-01-02 Thread GitBox

eolivelli commented on a change in pull request #31: URL: https://github.com/apache/pulsar-adapters/pull/31#discussion_r777321048 ## File path: pulsar-spark/src/main/scala/org/apache/spark/streaming/pulsar/SparkStreamingReliablePulsarReceiver.scala ## @@ -0,0 +1,181 @@ +/** +

[GitHub] [pulsar-adapters] eolivelli commented on a change in pull request #31: [Issue #29] [pulsar-spark] Adding SparkPulsarReliableReceiver

2021-12-28 Thread GitBox

eolivelli commented on a change in pull request #31: URL: https://github.com/apache/pulsar-adapters/pull/31#discussion_r776054579 ## File path: pulsar-spark/src/main/scala/org/apache/pulsar/spark/SparkStreamingReliablePulsarReceiver.scala ## @@ -0,0 +1,158 @@ +package org.apac