We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 647bb2b commit 9e785e3Copy full SHA for 9e785e3
examples/topic/reader_example.py
@@ -9,6 +9,7 @@ def connect():
9
credentials=ydb.credentials.AnonymousCredentials(),
10
)
11
reader = db.topic_client.reader("/local/topic", consumer="consumer")
12
+ #use your consumer
13
return reader
14
15
@@ -108,3 +109,13 @@ def handle_partition_graceful_stop_batch(reader: ydb.TopicReader):
108
109
110
def _process(msg):
111
raise NotImplementedError()
112
+
113
+#create new consumer, if you used thise one earlier
114
+#driver.topic_client.alter_topic(
115
+# "/local/topics",
116
+# add_consumers=[
117
+# ydb.TopicConsumer(
118
+# name="consumer6"
119
+# )
120
+# ]
121
+#)
0 commit comments