You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "feyman (Jira)" <ji...@apache.org> on 2020/05/23 02:31:00 UTC
[jira] [Created] (KAFKA-10035) Improve the
AbstractResetIntegrationTest
feyman created KAFKA-10035:
------------------------------
Summary: Improve the AbstractResetIntegrationTest
Key: KAFKA-10035
URL: https://issues.apache.org/jira/browse/KAFKA-10035
Project: Kafka
Issue Type: Improvement
Components: unit tests
Reporter: feyman
In this test AbstractResetIntegrationTest, there are several places like below:
```
streamsConfig.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, "" + STREAMS_CONSUMER_TIMEOUT * 100);
```
which leverage `Long` to `String` conversion as a workaround. or exception will be thrown if it is like:
```
streamsConfig.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, STREAMS_CONSUMER_TIMEOUT * 100);
```
Exception:
```
{{org.apache.kafka.common.config.ConfigException: Invalid value 200000 for configuration session.timeout.ms: Expected value to be a 32-bit integer, but it was a java.lang.Long
at org.apache.kafka.common.config.ConfigDef.parseType(ConfigDef.java:672)
at org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:474)
at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:467)
at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:108)
at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:129)
at org.apache.kafka.clients.consumer.ConsumerConfig.<init>(ConsumerConfig.java:606)
at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:630)
at org.apache.kafka.streams.processor.internals.DefaultKafkaClientSupplier.getRestoreConsumer(DefaultKafkaClientSupplier.java:56)
at org.apache.kafka.streams.processor.internals.StreamThread.create(StreamThread.java:313)
at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:766)
at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:652)
at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:562)
at org.apache.kafka.streams.integration.AbstractResetIntegrationTest.testResetWhenLongSessionTimeoutConfiguredWithForceOption(AbstractResetIntegrationTest.java:270)
at org.apache.kafka.streams.integration.ResetIntegrationTest.testResetWhenLongSessionTimeoutConfiguredWithForceOption(ResetIntegrationTest.java:77)}}
```
--
This message was sent by Atlassian Jira
(v8.3.4#803005)