Package io.smallrye.reactive.messaging.kafka.i18n

Interface KafkaLogging

  • All Superinterfaces:
    org.jboss.logging.BasicLogger
    All Known Implementing Classes:
    KafkaLogging_$logger
    @MessageLogger(projectCode="SRMSG",
               length=5)
public interface KafkaLogging
extends org.jboss.logging.BasicLogger
    Logging for Kafka Connector Assigned ID range is 18200-18299

    • Method Detail

      • deadLetterConfig

        @LogMessage(level=DEBUG)
@Message(id=18201,
         value="Dead queue letter configured with: topic: `%s`, key serializer: `%s`, value serializer: `%s`")
void deadLetterConfig​(String deadQueueTopic,
                      String keySerializer,
                      String valueSerializer)

      • messageNackedDeadLetter

        @LogMessage(level=INFO)
@Message(id=18202,
         value="A message sent to channel `%s` has been nacked, sending the record to a dead letter topic %s")
void messageNackedDeadLetter​(String channel,
                             String topic)

      • messageNackedFailStop

        @LogMessage(level=ERROR)
@Message(id=18203,
         value="A message sent to channel `%s` has been nacked, fail-stop")
void messageNackedFailStop​(String channel)

      • messageNackedIgnore

        @LogMessage(level=WARN)
@Message(id=18204,
         value="A message sent to channel `%s` has been nacked, ignored failure is: %s.")
void messageNackedIgnore​(String channel,
                         String reason)

      • messageNackedFullIgnored

        @LogMessage(level=DEBUG)
@Message(id=18205,
         value="The full ignored failure is")
void messageNackedFullIgnored​(@Cause
                              Throwable t)

      • unableToWrite

        @LogMessage(level=ERROR)
@Message(id=18206,
         value="Unable to write to Kafka from channel %s (topic: %s)")
void unableToWrite​(String channel,
                   String topic,
                   @Cause
                   Throwable t)

      • unableToWrite

        @LogMessage(level=ERROR)
@Message(id=18206,
         value="Unable to write to Kafka from channel %s (no topic set)")
void unableToWrite​(String channel,
                   @Cause
                   Throwable t)

      • unableToDispatch

        @LogMessage(level=ERROR)
@Message(id=18207,
         value="Unable to dispatch message to Kafka")
void unableToDispatch​(@Cause
                      Throwable t)

      • sendingMessageToTopic

        @LogMessage(level=DEBUG)
@Message(id=18209,
         value="Sending message %s to Kafka topic \'%s\'")
void sendingMessageToTopic​(Message message,
                           String topic)

      • unableToSendRecord

        @LogMessage(level=ERROR)
@Message(id=18210,
         value="Unable to send a record to Kafka ")
void unableToSendRecord​(@Cause
                        Throwable t)

      • successfullyToTopic

        @LogMessage(level=DEBUG)
@Message(id=18211,
         value="Message %s sent successfully to Kafka topic \'%s\'")
void successfullyToTopic​(Message message,
                         String topic)

      • nackingMessage

        @LogMessage(level=ERROR)
@Message(id=18212,
         value="Message %s was not sent to Kafka topic \'%s\' - nacking message")
void nackingMessage​(Message message,
                    String topic,
                    @Cause
                    Throwable t)

      • configServers

        @LogMessage(level=INFO)
@Message(id=18213,
         value="Setting %s to %s")
void configServers​(String serverConfig,
                   String servers)

      • keyDeserializerOmitted

        @LogMessage(level=INFO)
@Message(id=18214,
         value="Key deserializer omitted, using String as default")
void keyDeserializerOmitted()

      • errorWhileClosingWriteStream

        @LogMessage(level=DEBUG)
@Message(id=18215,
         value="An error has been caught while closing the Kafka Write Stream")
void errorWhileClosingWriteStream​(@Cause
                                  Throwable t)

      • noGroupId

        @LogMessage(level=WARN)
@Message(id=18216,
         value="No `group.id` set in the configuration, generate a random id: %s")
void noGroupId​(String randomId)

      • unableToReadRecord

        @LogMessage(level=ERROR)
@Message(id=18217,
         value="Unable to read a record from Kafka topics \'%s\'")
void unableToReadRecord​(Set<String> topics,
                        @Cause
                        Throwable t)

      • exceptionOnClose

        @LogMessage(level=DEBUG)
@Message(id=18218,
         value="An exception has been caught while closing the Kafka consumer")
void exceptionOnClose​(@Cause
                      Throwable t)

      • loadingConsumerRebalanceListenerFromConfiguredName

        @LogMessage(level=INFO)
@Message(id=18219,
         value="Loading KafkaConsumerRebalanceListener from configured name \'%s\'")
void loadingConsumerRebalanceListenerFromConfiguredName​(String configuredName)

      • loadingConsumerRebalanceListenerFromGroupId

        @LogMessage(level=INFO)
@Message(id=18220,
         value="Loading KafkaConsumerRebalanceListener from group id \'%s\'")
void loadingConsumerRebalanceListenerFromGroupId​(String consumerGroup)

      • unableToExecuteConsumerAssignedRebalanceListener

        @LogMessage(level=ERROR)
@Message(id=18221,
         value="Unable to execute consumer assigned re-balance listener for group \'%s\'. The consumer has been paused. Will retry until the consumer session times out in which case will resume to force a new re-balance attempt.")
void unableToExecuteConsumerAssignedRebalanceListener​(String consumerGroup,
                                                      @Cause
                                                      Throwable t)

      • unableToExecuteConsumerRevokedRebalanceListener

        @LogMessage(level=ERROR)
@Message(id=18222,
         value="Unable to execute consumer revoked re-balance listener for group \'%s\'")
void unableToExecuteConsumerRevokedRebalanceListener​(String consumerGroup,
                                                     @Cause
                                                     Throwable t)

      • executingConsumerAssignedRebalanceListener

        @LogMessage(level=INFO)
@Message(id=18223,
         value="Executing consumer assigned re-balance listener for group \'%s\'")
void executingConsumerAssignedRebalanceListener​(String consumerGroup)

      • executingConsumerRevokedRebalanceListener

        @LogMessage(level=INFO)
@Message(id=18224,
         value="Executing consumer revoked re-balance listener for group \'%s\'")
void executingConsumerRevokedRebalanceListener​(String consumerGroup)

      • executedConsumerAssignedRebalanceListener

        @LogMessage(level=INFO)
@Message(id=18225,
         value="Executed consumer assigned re-balance listener for group \'%s\'")
void executedConsumerAssignedRebalanceListener​(String consumerGroup)

      • executedConsumerRevokedRebalanceListener

        @LogMessage(level=INFO)
@Message(id=18226,
         value="Executed consumer revoked re-balance listener for group \'%s\'")
void executedConsumerRevokedRebalanceListener​(String consumerGroup)

      • reEnablingConsumerForGroup

        @LogMessage(level=WARN)
@Message(id=18227,
         value="Re-enabling consumer for group \'%s\'. This consumer was paused because of a re-balance failure.")
void reEnablingConsumerForGroup​(String consumerGroup)

      • failureReported

        @LogMessage(level=WARN)
@Message(id=18228,
         value="A failure has been reported for Kafka topics \'%s\'")
void failureReported​(Set<String> topics,
                     @Cause
                     Throwable t)

      • configuredTopics

        @LogMessage(level=INFO)
@Message(id=18229,
         value="Configured topics for channel \'%s\': %s")
void configuredTopics​(String channel,
                      Set<String> topics)

      • configuredPattern

        @LogMessage(level=INFO)
@Message(id=18230,
         value="Configured topics matching pattern for channel \'%s\': %s")
void configuredPattern​(String channel,
                       String pattern)

      • receivedTooManyMessagesWithoutAcking

        @LogMessage(level=WARN)
@Message(id=18231,
         value="The amount of received messages without acking is too high for topic partition \'%s\', amount %d.")
void receivedTooManyMessagesWithoutAcking​(String topicPartition,
                                          long amount)

      • settingCommitInterval

        @LogMessage(level=INFO)
@Message(id=18232,
         value="Will commit for group \'%s\' every %d milliseconds.")
void settingCommitInterval​(String group,
                           long commitInterval)

      • invalidValueSerializerForStructuredCloudEvent

        @LogMessage(level=ERROR)
@Message(id=18233,
         value="Invalid value serializer to write a structured Cloud Event. Found %d, expected the org.apache.kafka.common.serialization.StringSerializer")
void invalidValueSerializerForStructuredCloudEvent​(String serializer)

      • disableAutoCommit

        @LogMessage(level=INFO)
@Message(id=18234,
         value="Auto-commit disabled for channel %s")
void disableAutoCommit​(String channel)

      • disableThrottledCommitStrategyHealthCheck

        @LogMessage(level=WARN)
@Message(id=18235,
         value="Will not health check throttled commit strategy for group \'%s\'.")
void disableThrottledCommitStrategyHealthCheck​(String group)

      • setThrottledCommitStrategyReceivedRecordMaxAge

        @LogMessage(level=INFO)
@Message(id=18236,
         value="Will mark throttled commit strategy for group \'%s\' as unhealthy if records go more than %d milliseconds without being processed.")
void setThrottledCommitStrategyReceivedRecordMaxAge​(String group,
                                                    long unprocessedRecordMaxAge)

      • setKafkaProducerClientId

        @LogMessage(level=INFO)
@Message(id=18237,
         value="Setting client.id for Kafka producer to %s")
void setKafkaProducerClientId​(String name)

      • setKafkaConsumerClientId

        @LogMessage(level=INFO)
@Message(id=18238,
         value="Setting client.id for Kafka consumer to %s")
void setKafkaConsumerClientId​(String name)

      • messageAckedForRevokedTopicPartition

        @LogMessage(level=WARN)
@Message(id=18239,
         value="Acked record %d on group \'%s\' was ignored because the topic partition \'%s\' was revoked for this instance. Record will likely be processed again.")
void messageAckedForRevokedTopicPartition​(long offset,
                                          String groupId,
                                          String topicPartition)

      • commitStrategyForChannel

        @LogMessage(level=INFO)
@Message(id=18240,
         value="\'%s\' commit strategy used for channel \'%s\'")
void commitStrategyForChannel​(String strategy,
                              String channel)

      • deserializationFailureHandlerFailure

        @LogMessage(level=FATAL)
@Message(id=18241,
         value="The deserialization failure handler `%s` throws an exception")
void deserializationFailureHandlerFailure​(String instance,
                                          @Cause
                                          Throwable t)