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)

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