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	illegalArgumentInvalidStrategy(String strategy)
IllegalArgumentException	illegalArgumentNoMetadata(Class c)
IllegalArgumentException	illegalArgumentUnknownStrategy(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)

illegalArgumentUnknownStrategy

@Message(id=18001,
         value="Unknown failure strategy: %s")
IllegalArgumentException illegalArgumentUnknownStrategy(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()

illegalArgumentInvalidStrategy

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