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

Field Summary

Fields

Modifier and Type	Field and Description
static KafkaLogging	log

Method Summary

Modifier and Type	Method and Description
void	commitStrategyForChannel(String strategy, String channel)
void	configServers(String serverConfig, String servers)
void	configuredPattern(String channel, String pattern)
void	configuredTopics(String channel, Set<String> topics)
void	deadLetterConfig(String deadQueueTopic, String keySerializer, String valueSerializer)
void	deserializationFailureHandlerFailure(String instance, Throwable t)
void	disableAutoCommit(String channel)
void	disableThrottledCommitStrategyHealthCheck(String group)
void	errorWhileClosingWriteStream(Throwable t)
void	exceptionOnClose(Throwable t)
void	executedConsumerAssignedRebalanceListener(String consumerGroup)
void	executedConsumerRevokedRebalanceListener(String consumerGroup)
void	executingConsumerAssignedRebalanceListener(String consumerGroup)
void	executingConsumerRevokedRebalanceListener(String consumerGroup)
void	failureReported(Set<String> topics, Throwable t)
void	failureReportedDuringRebalance(Set<String> topics, Throwable t)
void	invalidValueSerializerForStructuredCloudEvent(String serializer)
void	keyDeserializerOmitted()
void	loadingConsumerRebalanceListenerFromConfiguredName(String configuredName)
void	loadingConsumerRebalanceListenerFromGroupId(String consumerGroup)
void	messageAckedForRevokedTopicPartition(long offset, String groupId, String topicPartition)
void	messageNackedDeadLetter(String channel, String topic)
void	messageNackedFailStop(String channel)
void	messageNackedFullIgnored(Throwable t)
void	messageNackedIgnore(String channel, String reason)
void	messageStillUnprocessedAfterTimeout(long unprocessed)
void	nackingMessage(Message message, String topic, Throwable t)
void	noGroupId(String randomId)
void	pauseAllPartitionOnTermination()
void	pausingChannel(String channel)
void	receivedTooManyMessagesWithoutAcking(String topicPartition, long amount, long lastCommittedOffset)
void	reEnablingConsumerForGroup(String consumerGroup)
void	resumingChannel(String channel)
void	sendingMessageToTopic(Message message, String topic)
void	setKafkaConsumerClientId(String name)
void	setKafkaProducerClientId(String name)
void	setThrottledCommitStrategyReceivedRecordMaxAge(String group, long unprocessedRecordMaxAge)
void	settingCommitInterval(String group, long commitInterval)
void	successfullyToTopic(Message message, String topic)
void	unableToDispatch(Throwable t)
void	unableToExecuteConsumerAssignedRebalanceListener(String consumerGroup, Throwable t)
void	unableToExecuteConsumerRevokedRebalanceListener(String consumerGroup, Throwable t)
void	unableToReadRecord(Set<String> topics, Throwable t)
void	unableToSendRecord(Throwable t)
void	unableToWrite(String channel, String topic, Throwable t)
void	unableToWrite(String channel, Throwable t)
void	waitingForMessageProcessing(long p)

Methods inherited from interface org.jboss.logging.BasicLogger

debug, debug, debug, debug, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugf, debugv, debugv, debugv, debugv, debugv, debugv, debugv, debugv, error, error, error, error, errorf, errorf, errorf, errorf, errorf, errorf, errorf, errorf, errorv, errorv, errorv, errorv, errorv, errorv, errorv, errorv, fatal, fatal, fatal, fatal, fatalf, fatalf, fatalf, fatalf, fatalf, fatalf, fatalf, fatalf, fatalv, fatalv, fatalv, fatalv, fatalv, fatalv, fatalv, fatalv, info, info, info, info, infof, infof, infof, infof, infof, infof, infof, infof, infov, infov, infov, infov, infov, infov, infov, infov, isDebugEnabled, isEnabled, isInfoEnabled, isTraceEnabled, log, log, log, log, logf, logf, logf, logf, logf, logf, logf, logf, logf, logf, logf, logf, logv, logv, logv, logv, logv, logv, logv, logv, logv, logv, logv, logv, trace, trace, trace, trace, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracef, tracev, tracev, tracev, tracev, tracev, tracev, tracev, tracev, warn, warn, warn, warn, warnf, warnf, warnf, warnf, warnf, warnf, warnf, warnf, warnv, warnv, warnv, warnv, warnv, warnv, warnv, warnv

Field Detail

log

static final KafkaLogging log

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)

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)

receivedTooManyMessagesWithoutAcking

@LogMessage(level=WARN)
 @Message(id=18231,
         value="The amount of received messages without acking is too high for topic partition \'%s\', amount %d. The last committed offset was %d. It means that the Kafka connector received Kafka Records that have neither be acked nor nacked in a timely fashion. The connector accumulates records in memory, but that buffer reached its maximum capacity or the deadline for ack/nack expired. The connector cannot commit as a record processing has not completed.")
void receivedTooManyMessagesWithoutAcking(String topicPartition,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      long amount,
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                      long lastCommittedOffset)

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)

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=INFO)
 @Message(id=18246,
         value="Pausing Kafka consumption for channel %s - not enough downstream requests")
void pausingChannel(String channel)

resumingChannel

@LogMessage(level=INFO)
 @Message(id=18247,
         value="Resuming Kafka consumption for channel %s")
void resumingChannel(String channel)