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

      • mergingConfigWith

        @LogMessage(level=INFO)
        @Message(id=18200,
                 value="Merging config with %s")
        void mergingConfigWith​(Map<String,​Object> defaultKafkaCfg)
      • 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")
        void unableToWrite​(@Cause
                           Throwable t)
      • unableToDispatch

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

        @LogMessage(level=ERROR)
        @Message(id=18208,
                 value="Ignoring message - no topic set")
        void ignoringNoTopicSet()
      • 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=DEBUG)
        @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="Consumed topics for channel \'%s\': %s")
        void configuredTopics​(String channel,
                              Set<String> topics)
      • configuredPattern

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