THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Deserializer<K> keyDeserializer,
Deserializer<V> valueDeserializer) {
}
A new Exception would be added:
public InvalidParameterException extends APIException
Proposed Changes
- As mentioned above, there would be an addition to KafkaConsumer, KafkaProducer and KafkaAdminClient
- An utility class will be added to map the string parameters to current configurations. That constructor would then delegate to the already existing code.
...
Invalid conversions would throw InvalidParameterException InvalidArgumentException (without with a description of the invalid conversion)
Invalid parameters would throw InvalidParameterException InvalidArgumentException (with the name of the invalid parameter).
...