You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: src/docs/asciidoc/super-streams.adoc
+30-1Lines changed: 30 additions & 1 deletion
Original file line number
Diff line number
Diff line change
@@ -233,7 +233,36 @@ Such a super stream consumer is a _composite consumer_.
233
233
So among these 9 consumer instances, only 3 are actually _active_, the other ones are idle or _inactive_.
234
234
* If one of the application instances stops, the broker will _rebalance_ its active consumer to one of the other instances.
235
235
236
-
The following figure illustrates how the consumer instances spread across the super stream partitions and which ones are active or inactive:
236
+
The following figure illustrates how the client library supports the combination of the super stream and single active consumer features.
237
+
It uses a composite consumer that creates an individual consumer for each partition of the super stream.
238
+
If there is only one single active consumer instance with a given name for a super stream, each individual consumer is active.
239
+
240
+
.A single active consumer on a super stream is a composite consumer that creates an individual consumer for each partition
241
+
[ditaa]
242
+
....
243
+
+--------------------+
244
+
| |
245
+
|cGRE invoices–0 |
246
+
| | +-------------------+
247
+
+--------------------+ |+-----------------+|
248
+
|+cGRE consumer ||Active
249
+
|+-----------------+|
250
+
invoices +--------------------+ | |
251
+
| | |+-----------------+|
252
+
|cPNK invoices–1 | |+cPNK consumer ||Active
253
+
| | |+-----------------+|
254
+
super stream +--------------------+ | |
255
+
|+-----------------+|
256
+
|+cBLU consumer ||Active
257
+
+--------------------+ |+-----------------+|
258
+
| | +-------------------+
259
+
|cBLU invoices–2 | Composite Consumer
260
+
| |
261
+
+--------------------+
262
+
....
263
+
264
+
Imagine now we start 3 instances of the consuming application to scale out the processing.
265
+
The individual consumer instances spread out across the super stream partitions and only one is active for each partition, as illustrated in the following figure:
237
266
238
267
.Consumer instances spread across the super stream partitions and are activated accordingly
0 commit comments