/AWS1/CL_KFKCONSUMERGROUPREPL¶
Details about consumer group replication.
CONSTRUCTOR¶
IMPORTING¶
Required arguments:¶
it_consumergroupstoreplicate TYPE /AWS1/CL_KFK__LSTOF__STRMAX200=>TT___LISTOF__STRINGMAX256 TT___LISTOF__STRINGMAX256¶
List of regular expression patterns indicating the consumer groups to copy.
Optional arguments:¶
it_consumergroupstoexclude TYPE /AWS1/CL_KFK__LSTOF__STRMAX200=>TT___LISTOF__STRINGMAX256 TT___LISTOF__STRINGMAX256¶
List of regular expression patterns indicating the consumer groups that should not be replicated.
iv_detectandcopynewconsgrps TYPE /AWS1/KFK__BOOLEAN /AWS1/KFK__BOOLEAN¶
Enables synchronization of consumer groups to target cluster.
iv_synchroniseconsgroupoffs TYPE /AWS1/KFK__BOOLEAN /AWS1/KFK__BOOLEAN¶
Enables synchronization of consumer group offsets to target cluster. The translated offsets will be written to topic __consumer_offsets.
iv_consgroupoffsetsyncmode TYPE /AWS1/KFKCONSGROUPOFFSYNCMODE /AWS1/KFKCONSGROUPOFFSYNCMODE¶
The consumer group offset synchronization mode. With LEGACY, offsets are synchronized when producers write to the source cluster. With ENHANCED, consumer offsets are synchronized regardless of producer location. ENHANCED requires a corresponding replicator that replicates data from the target cluster to the source cluster.
Queryable Attributes¶
ConsumerGroupsToExclude¶
List of regular expression patterns indicating the consumer groups that should not be replicated.
Accessible with the following methods¶
| Method | Description |
|---|---|
GET_CONSUMERGROUPSTOEXCLUDE() |
Getter for CONSUMERGROUPSTOEXCLUDE, with configurable defaul |
ASK_CONSUMERGROUPSTOEXCLUDE() |
Getter for CONSUMERGROUPSTOEXCLUDE w/ exceptions if field ha |
HAS_CONSUMERGROUPSTOEXCLUDE() |
Determine if CONSUMERGROUPSTOEXCLUDE has a value |
ConsumerGroupsToReplicate¶
List of regular expression patterns indicating the consumer groups to copy.
Accessible with the following methods¶
| Method | Description |
|---|---|
GET_CONSGROUPSTOREPLICATE() |
Getter for CONSUMERGROUPSTOREPLICATE, with configurable defa |
ASK_CONSGROUPSTOREPLICATE() |
Getter for CONSUMERGROUPSTOREPLICATE w/ exceptions if field |
HAS_CONSGROUPSTOREPLICATE() |
Determine if CONSUMERGROUPSTOREPLICATE has a value |
DetectAndCopyNewConsumerGroups¶
Enables synchronization of consumer groups to target cluster.
Accessible with the following methods¶
| Method | Description |
|---|---|
GET_DETECTANDCOPYNEWCONSGRPS() |
Getter for DETECTANDCOPYNEWCONSGROUPS, with configurable def |
ASK_DETECTANDCOPYNEWCONSGRPS() |
Getter for DETECTANDCOPYNEWCONSGROUPS w/ exceptions if field |
HAS_DETECTANDCOPYNEWCONSGRPS() |
Determine if DETECTANDCOPYNEWCONSGROUPS has a value |
SynchroniseConsumerGroupOffsets¶
Enables synchronization of consumer group offsets to target cluster. The translated offsets will be written to topic __consumer_offsets.
Accessible with the following methods¶
| Method | Description |
|---|---|
GET_SYNCHRONISECONSGROUPOFFS() |
Getter for SYNCHRONISECONSGROUPOFFSETS, with configurable de |
ASK_SYNCHRONISECONSGROUPOFFS() |
Getter for SYNCHRONISECONSGROUPOFFSETS w/ exceptions if fiel |
HAS_SYNCHRONISECONSGROUPOFFS() |
Determine if SYNCHRONISECONSGROUPOFFSETS has a value |
ConsumerGroupOffsetSyncMode¶
The consumer group offset synchronization mode. With LEGACY, offsets are synchronized when producers write to the source cluster. With ENHANCED, consumer offsets are synchronized regardless of producer location. ENHANCED requires a corresponding replicator that replicates data from the target cluster to the source cluster.
Accessible with the following methods¶
| Method | Description |
|---|---|
GET_CONSGROUPOFFSETSYNCMODE() |
Getter for CONSUMERGROUPOFFSETSYNCMODE, with configurable de |
ASK_CONSGROUPOFFSETSYNCMODE() |
Getter for CONSUMERGROUPOFFSETSYNCMODE w/ exceptions if fiel |
HAS_CONSGROUPOFFSETSYNCMODE() |
Determine if CONSUMERGROUPOFFSETSYNCMODE has a value |