Consumer<String> consumer = client.newConsumer(Schema.STRING)
.topic("my-topic")
.subscriptionName("my-subscription")
.replicateSubscriptionState(true)
.subscribe();
Created
July 9, 2019 07:22
-
-
Save sijie/95e427af0b7a63650e636a2b31308dec to your computer and use it in GitHub Desktop.
Replicated Subscription Example
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment