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)
      • 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)
      • 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)
      • failureReportedDuringRebalance

        @LogMessage(level=WARN)
        @Message(id=18242,
                 value="A failure has been reported during a rebalance - the operation will be retried: \'%s\'")
        void failureReportedDuringRebalance​(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)
      • waitingForAckForTooLong

        @LogMessage(level=WARN)
        @Message(id=18231,
                 value="The record %d from topic-partition \'%s\' has waited for %s seconds to be acknowledged. This waiting time is greater than the configured threshold (%d ms). At the moment %d messages from this partition are awaiting acknowledgement. The last committed offset for this partition was %d. This error is due to a potential issue in the application which does not acknowledged the records in a timely fashion. The connector cannot commit as a record processing has not completed.")
        void waitingForAckForTooLong​(long offset,
                                     org.apache.kafka.common.TopicPartition topicPartition,
                                     long delay,
                                     long configInMs,
                                     long queueSize,
                                     long lastCommittedOffset)
      • settingCommitInterval

        @LogMessage(level=DEBUG)
        @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=DEBUG)
        @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=DEBUG)
        @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=DEBUG)
        @Message(id=18237,
                 value="Setting client.id for Kafka producer to %s")
        void setKafkaProducerClientId​(String name)
      • acknowledgementFromRevokedTopicPartition

        @LogMessage(level=DEBUG)
        @Message(id=18239,
                 value="Received acknowledgement for record %d on \'%s\' (consumer group: \'%s\'). Ignoring it because the partition is not assigned to the consume anymore. Record will likely be processed again. Current assignments are %s.")
        void acknowledgementFromRevokedTopicPartition​(long offset,
                                                      org.apache.kafka.common.TopicPartition topicPartition,
                                                      String groupId,
                                                      Collection<org.apache.kafka.common.TopicPartition> assignments)
      • commitStrategyForChannel

        @LogMessage(level=DEBUG)
        @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)
      • pauseAllPartitionOnTermination

        @LogMessage(level=DEBUG)
        @Message(id=18243,
                 value="Shutting down - Pausing all topic-partitions")
        void pauseAllPartitionOnTermination()
      • waitingForMessageProcessing

        @LogMessage(level=DEBUG)
        @Message(id=18244,
                 value="Shutting down - Waiting for message processing to complete, %d messages still in processing")
        void waitingForMessageProcessing​(long p)
      • messageStillUnprocessedAfterTimeout

        @LogMessage(level=WARN)
        @Message(id=18245,
                 value="There are still %d unprocessed messages after the closing timeout")
        void messageStillUnprocessedAfterTimeout​(long unprocessed)
      • pausingChannel

        @LogMessage(level=DEBUG)
        @Message(id=18246,
                 value="Pausing Kafka consumption for channel %s, queue size %s is more than %s")
        void pausingChannel​(String channel,
                            int queueSize,
                            int maxQueueSize)
      • resumingChannel

        @LogMessage(level=DEBUG)
        @Message(id=18247,
                 value="Resuming Kafka consumption for channel %s, queue size %s is less than %s")
        void resumingChannel​(String channel,
                             int queueSize,
                             int halfMaxQueueSize)
      • keySerializerOmitted

        @LogMessage(level=DEBUG)
        @Message(id=18248,
                 value="Key serializer omitted, using String as default")
        void keySerializerOmitted()
      • unableToDeserializeMessage

        @LogMessage(level=ERROR)
        @Message(id=18249,
                 value="Unable to recover from the deserialization failure (topic: %s), configure a DeserializationFailureHandler to recover from errors.")
        void unableToDeserializeMessage​(String topic,
                                        @Cause
                                        Throwable t)
      • deprecatedConfig

        @LogMessage(level=WARN)
        @Message(id=18250,
                 value="The configuration property \'%s\' is deprecated and is replaced by \'%s\'.")
        void deprecatedConfig​(String deprecated,
                              String replace)
      • committed

        @LogMessage(level=DEBUG)
        @Message(id=18251,
                 value="Committed %s")
        void committed​(Map<org.apache.kafka.common.TopicPartition,​org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets)
      • failedToCommit

        @LogMessage(level=WARN)
        @Message(id=18252,
                 value="Failed to commit %s, it will be re-attempted")
        void failedToCommit​(Map<org.apache.kafka.common.TopicPartition,​org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets,
                            @Cause
                            Throwable failure)
      • removingPartitionFromStore

        @LogMessage(level=DEBUG)
        @Message(id=18253,
                 value="Removing topic-partition \'%s\' from the store - the partition is not assigned to the consumer anymore. Current assignments are: %s")
        void removingPartitionFromStore​(org.apache.kafka.common.TopicPartition tp,
                                        Collection<org.apache.kafka.common.TopicPartition> assignments)
      • partitionRevokedCollectingRecordsToCommit

        @LogMessage(level=DEBUG)
        @Message(id=18254,
                 value="Topic-partition \'%s\' has been revoked - going to commit offset %d")
        void partitionRevokedCollectingRecordsToCommit​(org.apache.kafka.common.TopicPartition partition,
                                                       long commit)
      • receivedOutdatedOffset

        @LogMessage(level=DEBUG)
        @Message(id=18255,
                 value="Received a record from topic-partition \'%s\' at offset %d, while the last committed offset is %d - Ignoring record")
        void receivedOutdatedOffset​(org.apache.kafka.common.TopicPartition topicPartition,
                                    long offset,
                                    long lastCommitted)
      • initializeStoreAtPosition

        @LogMessage(level=INFO)
        @Message(id=18256,
                 value="Initialize record store for topic-partition \'%s\' at position %d.")
        void initializeStoreAtPosition​(org.apache.kafka.common.TopicPartition topicPartition,
                                       long position)
      • connectedToKafka

        @LogMessage(level=INFO)
        @Message(id=18257,
                 value="Kafka consumer %s, connected to Kafka brokers \'%s\', belongs to the \'%s\' consumer group and is configured to poll records from %s")
        void connectedToKafka​(String id,
                              String bootstrapServers,
                              String consumerGroup,
                              Set<String> topics)
      • connectedToKafka

        @LogMessage(level=INFO)
        @Message(id=18258,
                 value="Kafka producer %s, connected to Kafka brokers \'%s\', is configured to write records to \'%s\'")
        void connectedToKafka​(String id,
                              String bootstrapServers,
                              String topic)
      • failedToCommitAsync

        @LogMessage(level=WARN)
        @Message(id=18259,
                 value="Kafka latest commit strategy failed to commit record from topic-partition \'%s\' at offset %d")
        void failedToCommitAsync​(org.apache.kafka.common.TopicPartition topicPartition,
                                 long offset)
      • unableToSerializeMessage

        @LogMessage(level=ERROR)
        @Message(id=18260,
                 value="Unable to recover from the serialization failure (topic: %s), configure a SerializationFailureHandler to recover from errors.")
        void unableToSerializeMessage​(String topic,
                                      @Cause
                                      Throwable t)