Skip to content

Commit 5793e05

Browse files
lamluongbinhMichael Lam
authored andcommitted
fix: configure idleTimeoutUnit as MILLISECONDS to avoid long client wait
1 parent 4f920dd commit 5793e05

File tree

3 files changed

+8
-0
lines changed

3 files changed

+8
-0
lines changed

data-plane/config/channel/100-config-kafka-channel-data-plane.yaml

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -79,8 +79,10 @@ data:
7979
# for each method starting with `set` there is a property that can be set with the name that follows the `set`
8080
# prefix starting with a lowercase letter.
8181
# For example, there is a method called `setIdleTimeout` and the associated property is `idleTimeout`.
82+
# idleTimeoutUnit is optional and defaults to SECONDS if not specified.
8283
config-kafka-channel-webclient.properties: |
8384
idleTimeout=10000
85+
idleTimeoutUnit=MILLISECONDS
8486
config-kafka-channel-producer.properties: |
8587
key.serializer=org.apache.kafka.common.serialization.StringSerializer
8688
value.serializer=io.cloudevents.kafka.CloudEventSerializer
@@ -174,6 +176,7 @@ data:
174176
# ssl.trustmanager.algorithm
175177
config-kafka-channel-webclient.properties: |
176178
idleTimeout=10000
179+
idleTimeoutUnit=MILLISECONDS
177180
maxPoolSize=100
178181
config-kafka-channel-httpserver.properties: |
179182
idleTimeout=0

data-plane/config/source/100-config-kafka-source-data-plane.yaml

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -59,8 +59,10 @@ data:
5959
# for each method starting with `set` there is a property that can be set with the name that follows the `set`
6060
# prefix starting with a lowercase letter.
6161
# For example, there is a method called `setIdleTimeout` and the associated property is `idleTimeout`.
62+
# idleTimeoutUnit is optional and defaults to SECONDS if not specified.
6263
config-kafka-source-webclient.properties: |
6364
idleTimeout=10000
65+
idleTimeoutUnit=MILLISECONDS
6466
config-kafka-source-producer.properties: |
6567
key.serializer=org.apache.kafka.common.serialization.StringSerializer
6668
value.serializer=io.cloudevents.kafka.CloudEventSerializer
@@ -157,4 +159,5 @@ data:
157159
# ssl.trustmanager.algorithm
158160
config-kafka-source-webclient.properties: |
159161
idleTimeout=10000
162+
idleTimeoutUnit=MILLISECONDS
160163
maxPoolSize=100

data-plane/profiler/resources/config-kafka-broker-webclient.properties

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,5 +13,7 @@
1313
# See the License for the specific language governing permissions and
1414
# limitations under the License.
1515
#
16+
# idleTimeoutUnit is optional and defaults to SECONDS if not specified.
1617

1718
idleTimeout=10000
19+
idleTimeoutUnit=MILLISECONDS

0 commit comments

Comments
 (0)