Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
  • Loading branch information
shishkovilja committed Jan 19, 2023
1 parent 35ede1e commit f8671c8
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -113,7 +113,7 @@ image:../../assets/images/integrations/CDC-ignite2kafka.svg[]
| `kafkaRequestTimeout` | Kafka request timeout in milliseconds. | `3000`
|===

NOTE: `kafkaRequestTimeout` property sets how much `IgniteToKafkaCdcStreamer` will wait for `KafkaProducer` to finish request. _Too low value_ of this timeout can lead to a failure of `IgniteToKafkaCdcStreamer` because of possible delays in network or on Kafka broker. Also, proper `KafkaProducer` configuration should be provided, including link:https://kafka.apache.org/documentation/#producerconfigs_request.timeout.ms[request.timeout.ms]. For more details you should refer to a link:https://kafka.apache.org/documentation/#configuration[configuration] section of the official Kafka documentation.
NOTE: `kafkaRequestTimeout` property sets how much `IgniteToKafkaCdcStreamer` will wait for `KafkaProducer` to finish request. _Too low value_ of this timeout can lead to frequent failures of `IgniteToKafkaCdcStreamer` because of possible delays in network or on Kafka broker. Also, proper `KafkaProducer` configuration should be provided, including link:https://kafka.apache.org/documentation/#producerconfigs_request.timeout.ms[request.timeout.ms]. For more details you should refer to a link:https://kafka.apache.org/documentation/#configuration[configuration] section of the official Kafka documentation.

=== IgniteToKafkaCdcStreamer Metrics

Expand Down Expand Up @@ -177,7 +177,7 @@ Kafka to Ignite configuration file should contain the following beans that will
| `threadCount` | Count of threads to proceed consumers. Each thread poll records from dedicated partitions in round-robin manner. | 16
|===

NOTE: Under the hood `kafka-to-ignite.sh` polls data from a Kafka very frequently (with a small interval). `kafkaRequestTimeout` property sets timeouts for a folllowing `KafkaConsumer` operations: offsets committing and closing of a consumer. _Too low value_ of this timeout can lead to a failure of `kafka-to-ignite.sh` because of possible delays in network or on Kafka broker. Also, proper `KafkaConsumer` configuration should be provided, including link:https://kafka.apache.org/documentation/#consumerconfigs_request.timeout.ms[request.timeout.ms]. For more details you should refer to a link:https://kafka.apache.org/documentation/#configuration[configuration] section of the official Kafka documentation.
NOTE: Under the hood `kafka-to-ignite.sh` polls data from a Kafka very frequently (with a small interval). `kafkaRequestTimeout` property sets timeouts for a folllowing `KafkaConsumer` operations: offsets committing and closing of a consumer. _Too low value_ of this timeout can lead to frequent failures of `kafka-to-ignite.sh` because of possible delays in network or on Kafka broker. Also, proper `KafkaConsumer` configuration should be provided, including link:https://kafka.apache.org/documentation/#consumerconfigs_request.timeout.ms[request.timeout.ms]. For more details you should refer to a link:https://kafka.apache.org/documentation/#configuration[configuration] section of the official Kafka documentation.

==== Logging

Expand Down

0 comments on commit f8671c8

Please sign in to comment.