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

        @Message(id=18016,
                 value="Unable to find the SerializationFailureHandler named `%s` for channel `%s`")
        javax.enterprise.inject.UnsatisfiedResolutionException unableToFindSerializationFailureHandler​(String name,
                                                                                                       String channel)
      • unableToFindSerializationFailureHandler

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