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:

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 from KafkaConsumer.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(String message)
UnsupportedVersionException(String message, Throwable cause)

Method Summary

Methods inherited from class org.apache.kafka.common.errors.ApiException

fillInStackTrace

Methods inherited from class java.lang.Throwable

addSuppressed, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

UnsupportedVersionException

public UnsupportedVersionException(String message,
                                   Throwable cause)

UnsupportedVersionException

public UnsupportedVersionException(String message)