autoCommitIntervalMs must be int instead of long

bootique / bootique-kafka

Provides integration of Kafka client and streams with Bootique

http://bootique.io

Apache License 2.0

4 stars 4 forks source link

autoCommitIntervalMs must be int instead of long #13

Closed vvertinskiy closed 6 years ago

vvertinskiy commented 6 years ago

Configuration property kafkaclient -> consumer -> autoCommitIntervalMs must be integer, not long, because org.apache.kafka.clients.consumer.ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG is defined as INT (for long type exception occurs "throw new ConfigException(name, value, "Expected value to be a 32-bit integer, but it was a long");"