Package 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

    • 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)

      • 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)

      • missingProperty

        @Message(id=18014,
         value="The config property \'%s\' is required but it could not be found in any config source")
NoSuchElementException missingProperty​(String propertyName)

      • cannotConvertProperty

        @Message(id=18015,
         value="Cannot convert property \'%s\' of type %s to %s")
NoSuchElementException cannotConvertProperty​(String propertyName,
                                             Class<?> type,
                                             Class<?> targetType)