[solr-sandbox] branch crossdc-wip updated: Apply request timeout for kafka to consumer as well. (#62)

[ma...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

markrmiller pushed a commit to branch crossdc-wip
in repository https://gitbox.apache.org/repos/asf/solr-sandbox.git


The following commit(s) were added to refs/heads/crossdc-wip by this push:
     new d674689  Apply request timeout for kafka to consumer as well. (#62)
d674689 is described below

commit d674689fba7cdb3fd209b79db001d9fc1ca9cab8
Author: Mark Robert Miller <ma...@apache.org>
AuthorDate: Tue Jun 13 13:17:41 2023 -0500

    Apply request timeout for kafka to consumer as well. (#62)
---
 .../java/org/apache/solr/crossdc/consumer/KafkaCrossDcConsumer.java     | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/crossdc-consumer/src/main/java/org/apache/solr/crossdc/consumer/KafkaCrossDcConsumer.java b/crossdc-consumer/src/main/java/org/apache/solr/crossdc/consumer/KafkaCrossDcConsumer.java
index 2f66d0f..e01645f 100644
--- a/crossdc-consumer/src/main/java/org/apache/solr/crossdc/consumer/KafkaCrossDcConsumer.java
+++ b/crossdc-consumer/src/main/java/org/apache/solr/crossdc/consumer/KafkaCrossDcConsumer.java
@@ -66,6 +66,8 @@ public class KafkaCrossDcConsumer extends Consumer.CrossDcConsumer {
     kafkaConsumerProps.put(ConsumerConfig.FETCH_MAX_BYTES_CONFIG, conf.getInt(KafkaCrossDcConf.FETCH_MAX_BYTES));
     kafkaConsumerProps.put(ConsumerConfig.MAX_PARTITION_FETCH_BYTES_CONFIG, conf.getInt(KafkaCrossDcConf.MAX_PARTITION_FETCH_BYTES));
 
+    kafkaConsumerProps.put(ConsumerConfig.REQUEST_TIMEOUT_MS_CONFIG, conf.getInt(KafkaCrossDcConf.REQUEST_TIMEOUT_MS));
+
     KafkaCrossDcConf.addSecurityProps(conf, kafkaConsumerProps);
 
     kafkaConsumerProps.putAll(conf.getAdditionalProperties());