alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-6260 Reformat text; add injection points

Browse Source
This commit is contained in:
Jiri Pechanec 2023-04-18 08:10:39 +02:00
parent bb5b07e7e1
commit e9db1c4829
1 changed files with 26 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
documentation/modules/ROOT/pages/operations/debezium-server.adoc
View File

@ -1324,7 +1324,7 @@ proper value based on the actual application to avoid long thread blocking time.
===== Injection points ===== Injection points
The rocketmq sink behaviour can be modified by a custom logic providing alternative implementations for specific The RocketMQ sink behaviour can be modified by a custom logic providing alternative implementations for specific
functionalities. functionalities.
When the alternative implementations are not available then the default ones are used. When the alternative implementations are not available then the default ones are used.
@ -1337,12 +1337,18 @@ When the alternative implementations are not available then the default ones are
|[[rocketmq-producer]]<<rocketmq-producer, `org.apache.rocketmq.client.producer.DefaultMQProducer`>> |[[rocketmq-producer]]<<rocketmq-producer, `org.apache.rocketmq.client.producer.DefaultMQProducer`>>
|`@CustomConsumerBuilder` |`@CustomConsumerBuilder`
|Custom configured instance of a RocketMQ used to publish messages to target topic. |Custom configured instance of a RocketMQ used to publish messages to target topic.
|[[rocketmq-ext-stream-name-mapper]]<<rocketmq-ext-stream-name-mapper, `io.debezium.server.StreamNameMapper`>>
|
|Custom implementation maps the planned destination (stream) name into a RocketMQ topic name.
By default the same name is used.
|=== |===
==== RabbitMQ Stream ==== RabbitMQ Stream
https://www.rabbitmq.com/[RabbitMQ] is an open source message broker, supporting multiple messaging protocols and can be deployed in distributed and federated configurations to meet high-scale, high-availability requirements. RabbitMQ supports messages queues and streams. Debezium server supports publishing https://www.rabbitmq.com/[RabbitMQ] is an open source message broker, supporting multiple messaging protocols and can be deployed in distributed and federated configurations to meet high-scale, high-availability requirements.
captured change events to a configured RabbitMQ Stream. RabbitMQ supports messages queues and streams.
Debezium Server supports publishing captured change events to a configured RabbitMQ Stream.
[cols="35%a,10%a,55%a",options="header"] [cols="35%a,10%a,55%a",options="header"]
|=== |===
@ -1378,6 +1384,23 @@ The connection https://github.com/rabbitmq/rabbitmq-java-client/blob/main/src/ma
|=== |===
===== Injection points
RabbitMQ sink behavior can be modified by custom logic providing alternative implementations for specific functionalities.
When the alternative implementations are not available then the default ones are used.
[cols="35%a,10%a,55%a",options="header"]
|===
|Interface
|CDI classifier
|Description
|[[rabbitmq-ext-stream-name-mapper]]<<rabbitmq-ext-stream-name-mapper, `io.debezium.server.StreamNameMapper`>>
|
|Custom implementation maps the planned destination (stream) name into a RabbitMQ exchange name.
By default the same name is used.
|===
== Extensions == Extensions
{prodname} Server uses the https://quarkus.io/[Quarkus framework] and relies on dependency injection to enable developer to extend its behaviour. {prodname} Server uses the https://quarkus.io/[Quarkus framework] and relies on dependency injection to enable developer to extend its behaviour.