Package org.apache.kafka.common.errors
Class UnsupportedVersionException
- java.lang.Object
-
- java.lang.Throwable
-
- java.lang.Exception
-
- java.lang.RuntimeException
-
- org.apache.kafka.common.KafkaException
-
- org.apache.kafka.common.errors.ApiException
-
- org.apache.kafka.common.errors.UnsupportedVersionException
-
- All Implemented Interfaces:
java.io.Serializable
public class UnsupportedVersionException extends ApiException
Indicates that a request API or version needed by the client is not supported by the broker. This is typically a fatal error as Kafka clients will downgrade request versions as needed except in cases where a needed feature is not available in old versions. Fatal errors can generally only be handled by closing the client instance, although in some cases it may be possible to continue without relying on the underlying feature. For example, when the producer is used with idempotence enabled, this error is fatal since the producer does not support reverting to weaker semantics. On the other hand, if this error is raised fromKafkaConsumer.offsetsForTimes(Map)
, it would be possible to revert to alternative logic to set the consumer's position.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description UnsupportedVersionException(java.lang.String message)
UnsupportedVersionException(java.lang.String message, java.lang.Throwable cause)
-
Method Summary
-
Methods inherited from class org.apache.kafka.common.errors.ApiException
fillInStackTrace
-
-