Skip to content

Commit fe81918

Browse files
committed
Added null check for generate.timeout validator
1 parent 9610758 commit fe81918

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

src/main/java/io/confluent/kafka/connect/datagen/DatagenConnectorConfig.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -216,6 +216,9 @@ private static class GenerateTimeoutValidator implements Validator {
216216

217217
@Override
218218
public void ensureValid(String name, Object value) {
219+
if (value == null) {
220+
return;
221+
}
219222
Long longValue = (Long) value;
220223
if (longValue > 0 && longValue <= 60000L) {
221224
return;

0 commit comments

Comments
 (0)