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

Field Summary

Fields

Modifier and Type	Field	Description
static KafkaExceptions	ex

Method Summary

Modifier and Type	Method	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()

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)