Skip to content

Commit 159dd7f

Browse files
committed
Add figure for SAC + super stream
References #46
1 parent a713b67 commit 159dd7f

File tree

2 files changed

+46
-17
lines changed

2 files changed

+46
-17
lines changed

pom.xml

Lines changed: 16 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -417,22 +417,22 @@
417417

418418
</configuration>
419419
<executions>
420-
<execution>
421-
<id>generate-pdf</id>
422-
<phase>pre-site</phase>
423-
<goals>
424-
<goal>process-asciidoc</goal>
425-
</goals>
426-
<configuration>
427-
<backend>pdf</backend>
428-
<attributes>
429-
<title-page />
430-
<toc />
431-
<toclevels>4</toclevels>
432-
<pagenums />
433-
</attributes>
434-
</configuration>
435-
</execution>
420+
<!-- <execution>-->
421+
<!-- <id>generate-pdf</id>-->
422+
<!-- <phase>pre-site</phase>-->
423+
<!-- <goals>-->
424+
<!-- <goal>process-asciidoc</goal>-->
425+
<!-- </goals>-->
426+
<!-- <configuration>-->
427+
<!-- <backend>pdf</backend>-->
428+
<!-- <attributes>-->
429+
<!-- <title-page />-->
430+
<!-- <toc />-->
431+
<!-- <toclevels>4</toclevels>-->
432+
<!-- <pagenums />-->
433+
<!-- </attributes>-->
434+
<!-- </configuration>-->
435+
<!-- </execution>-->
436436
<execution>
437437
<id>generate-html</id>
438438
<phase>pre-site</phase>

src/docs/asciidoc/super-streams.adoc

Lines changed: 30 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -233,7 +233,36 @@ Such a super stream consumer is a _composite consumer_.
233233
So among these 9 consumer instances, only 3 are actually _active_, the other ones are idle or _inactive_.
234234
* If one of the application instances stops, the broker will _rebalance_ its active consumer to one of the other instances.
235235

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:
237266

238267
.Consumer instances spread across the super stream partitions and are activated accordingly
239268
[ditaa]

0 commit comments

Comments
 (0)