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

2021-05-17 Thread GitBox
dlg99 commented on a change in pull request #10498: URL: https://github.com/apache/pulsar/pull/10498#discussion_r633911631 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java ## @@ -706,4 +714,67 @@ public void close() {

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

2021-05-17 Thread GitBox
dlg99 commented on a change in pull request #10498: URL: https://github.com/apache/pulsar/pull/10498#discussion_r633740600 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java ## @@ -706,4 +714,67 @@ public void close() {

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

2021-05-17 Thread GitBox
dlg99 commented on a change in pull request #10498: URL: https://github.com/apache/pulsar/pull/10498#discussion_r633740600 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java ## @@ -706,4 +714,67 @@ public void close() {

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

2021-05-14 Thread GitBox
dlg99 commented on a change in pull request #10498: URL: https://github.com/apache/pulsar/pull/10498#discussion_r632659889 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java ## @@ -706,4 +714,67 @@ public void close() {

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

2021-05-13 Thread GitBox
dlg99 commented on a change in pull request #10498: URL: https://github.com/apache/pulsar/pull/10498#discussion_r632325403 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java ## @@ -706,4 +714,67 @@ public void close() {

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

2021-05-13 Thread GitBox
dlg99 commented on a change in pull request #10498: URL: https://github.com/apache/pulsar/pull/10498#discussion_r632324796 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java ## @@ -706,4 +714,67 @@ public void close() {

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

2021-05-13 Thread GitBox
dlg99 commented on a change in pull request #10498: URL: https://github.com/apache/pulsar/pull/10498#discussion_r632323145 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java ## @@ -706,4 +714,67 @@ public void close() {

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

2021-05-11 Thread GitBox
dlg99 commented on a change in pull request #10498: URL: https://github.com/apache/pulsar/pull/10498#discussion_r630431285 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java ## @@ -706,4 +710,41 @@ public void close() {

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

2021-05-11 Thread GitBox
dlg99 commented on a change in pull request #10498: URL: https://github.com/apache/pulsar/pull/10498#discussion_r630431079 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/MultiConsumerPulsarSource.java ## @@ -69,7 +72,20 @@ public void

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

2021-05-10 Thread GitBox
dlg99 commented on a change in pull request #10498: URL: https://github.com/apache/pulsar/pull/10498#discussion_r629744063 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/MultiConsumerPulsarSource.java ## @@ -69,7 +72,20 @@ public void