[GitHub] [pulsar] eolivelli commented on a change in pull request #10498: SinkContext: ability to seek/pause/resume consumer for a topic

eolivelli commented on a change in pull request #10498: URL: https://github.com/apache/pulsar/pull/10498#discussion_r632333045 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java ## @@ -706,4 +714,67 @@ public void close(

[GitHub] [pulsar] eolivelli commented on a change in pull request #10498: SinkContext: ability to seek/pause/resume consumer for a topic

eolivelli commented on a change in pull request #10498: URL: https://github.com/apache/pulsar/pull/10498#discussion_r632332932 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java ## @@ -706,4 +714,67 @@ public void close(

[GitHub] [pulsar] eolivelli commented on a change in pull request #10498: SinkContext: ability to seek/pause/resume consumer for a topic

eolivelli commented on a change in pull request #10498: URL: https://github.com/apache/pulsar/pull/10498#discussion_r632314094 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java ## @@ -706,4 +714,67 @@ public void close(

[GitHub] [pulsar] eolivelli commented on a change in pull request #10498: SinkContext: ability to seek/pause/resume consumer for a topic

eolivelli commented on a change in pull request #10498: URL: https://github.com/apache/pulsar/pull/10498#discussion_r630086497 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/MultiConsumerPulsarSource.java ## @@ -69,7 +72,20 @@ public v