Commit aec2d76
authored
Fix arguments' types causing exception (linkedin#387)
### Problem
- Exception
```
Exception in thread "main" java.lang.ClassCastException: class java.lang.Long cannot be cast to class java.lang.Integer (java.lang.Long and java.lang.Integer are in module java.base of loader 'bootstrap')
at org.apache.kafka.common.config.AbstractConfig.getInt(AbstractConfig.java:173)
at com.linkedin.xinfra.monitor.services.OffsetCommitService.<init>(OffsetCommitService.java:132)
at com.linkedin.xinfra.monitor.services.OffsetCommitServiceFactory.createService(OffsetCommitServiceFactory.java:53)
at com.linkedin.xinfra.monitor.XinfraMonitor.<init>(XinfraMonitor.java:82)
at com.linkedin.xinfra.monitor.XinfraMonitor.main(XinfraMonitor.java:186)
```
- linkedin#378 upgade introduced new [arguments for Network client `long connectionSetupTimeoutMs` and `long connectionSetupTimeoutMaxMs`](https://github.com/linkedin/kafka-monitor/pull/378/files#diff-2d490a032d59e6cc9ec2d94cc7fe4311f08a01d1cd67de185dd8e005fa582cd3R131)
- but mistakenly used `getInt` instead of expected `getLong`
## Solition
- use expected `getLong` method
## TODO
- increase test coverage to avoid future regressions1 parent 57e442e commit aec2d76
File tree
1 file changed
+1
-1
lines changed- src/main/java/com/linkedin/xinfra/monitor/services
1 file changed
+1
-1
lines changedLines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
129 | 129 | | |
130 | 130 | | |
131 | 131 | | |
132 | | - | |
| 132 | + | |
133 | 133 | | |
134 | 134 | | |
135 | 135 | | |
| |||
0 commit comments