io.smallrye.reactive.messaging.kafka.i18n

Interface KafkaExceptions

All Known Implementing Classes:

KafkaExceptions_$bundle

@MessageBundle(projectCode="SRMSG",
               length=5)
public interface KafkaExceptions

Exceptions for Kafka Connector Assigned ID range is 18000-18099

Field Summary

Fields

Modifier and Type	Field and Description
static KafkaExceptions	ex

Method Summary

Modifier and Type	Method and Description
IllegalArgumentException	illegalArgumentInvalidCommitStrategy(String strategy)
IllegalArgumentException	illegalArgumentInvalidFailureStrategy(String strategy)
IllegalArgumentException	illegalArgumentNoMetadata(Class c)
IllegalArgumentException	illegalArgumentUnknownCommitStrategy(String strategy)
IllegalArgumentException	illegalArgumentUnknownFailureStrategy(String strategy)
IllegalStateException	illegalStateConsumeWithoutBackPressure()
IllegalStateException	illegalStateOnlyOneSubscriber()
IllegalArgumentException	missingValueDeserializer(String channel, String channelAgain)
IllegalArgumentException	missingValueSerializer(String channel, String channelAgain)
IllegalArgumentException	unableToCreateInstance(String clazz, Throwable cause)
javax.enterprise.inject.UnsatisfiedResolutionException	unableToFindDeserializationFailureHandler(String name, String channel)
javax.enterprise.inject.AmbiguousResolutionException	unableToFindDeserializationFailureHandler(String name, String channel, int count)
javax.enterprise.inject.UnsatisfiedResolutionException	unableToFindRebalanceListener(String name, String channel)
javax.enterprise.inject.AmbiguousResolutionException	unableToFindRebalanceListener(String name, String channel, int count)

Field Detail

ex

static final KafkaExceptions ex

Method Detail

illegalArgumentNoMetadata

@Message(id=18000,
         value="`message` does not contain metadata of class %s")
IllegalArgumentException illegalArgumentNoMetadata(Class c)

illegalArgumentUnknownFailureStrategy

@Message(id=18001,
         value="Unknown failure strategy: %s")
IllegalArgumentException illegalArgumentUnknownFailureStrategy(String strategy)

illegalStateConsumeWithoutBackPressure

@Message(id=18002,
         value="Expecting downstream to consume without back-pressure")
IllegalStateException illegalStateConsumeWithoutBackPressure()

illegalStateOnlyOneSubscriber

@Message(id=18003,
         value="Only one subscriber allowed")
IllegalStateException illegalStateOnlyOneSubscriber()

illegalArgumentInvalidFailureStrategy

@Message(id=18004,
         value="Invalid failure strategy: %s")
IllegalArgumentException illegalArgumentInvalidFailureStrategy(String strategy)

illegalArgumentUnknownCommitStrategy

@Message(id=18005,
         value="Unknown commit strategy: %s")
IllegalArgumentException illegalArgumentUnknownCommitStrategy(String strategy)

illegalArgumentInvalidCommitStrategy

@Message(id=18006,
         value="Invalid commit strategy: %s")
IllegalArgumentException illegalArgumentInvalidCommitStrategy(String strategy)

unableToFindRebalanceListener

@Message(id=18007,
         value="Unable to find the KafkaConsumerRebalanceListener named `%s` for channel `%s`")
javax.enterprise.inject.UnsatisfiedResolutionException unableToFindRebalanceListener(String name,
                                                                                                                                                                                                        String channel)

unableToFindRebalanceListener

@Message(id=18008,
         value="Unable to select the KafkaConsumerRebalanceListener named `%s` for channel `%s` - too many matches (%d)")
javax.enterprise.inject.AmbiguousResolutionException unableToFindRebalanceListener(String name,
                                                                                                                                                                                                                                String channel,
                                                                                                                                                                                                                                int count)

missingValueDeserializer

@Message(id=18009,
         value="Cannot configure the Kafka consumer for channel `%s` - the `mp.messaging.incoming.%s.value.deserializer` property is missing")
IllegalArgumentException missingValueDeserializer(String channel,
                                                                                                                                                                                                                    String channelAgain)

unableToCreateInstance

@Message(id=18010,
         value="Unable to create an instance of `%s`")
IllegalArgumentException unableToCreateInstance(String clazz,
                                                                                                                          @Cause
                                                                                                                          Throwable cause)

unableToFindDeserializationFailureHandler

@Message(id=18011,
         value="Unable to find the DeserializationFailureHandler named `%s` for channel `%s`")
javax.enterprise.inject.UnsatisfiedResolutionException unableToFindDeserializationFailureHandler(String name,
                                                                                                                                                                                                                   String channel)

unableToFindDeserializationFailureHandler

@Message(id=18012,
         value="Unable to select the DeserializationFailureHandler named `%s` for channel `%s` - too many matches (%d)")
javax.enterprise.inject.AmbiguousResolutionException unableToFindDeserializationFailureHandler(String name,
                                                                                                                                                                                                                                           String channel,
                                                                                                                                                                                                                                           int count)

missingValueSerializer

@Message(id=18013,
         value="Cannot configure the Kafka producer for channel `%s` - the `mp.messaging.outgoing.%s.value.serializer` property is missing")
IllegalArgumentException missingValueSerializer(String channel,
                                                                                                                                                                                                                String channelAgain)