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)