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

Class KafkaLogging_$logger

java.lang.Object

org.jboss.logging.DelegatingBasicLogger

io.smallrye.reactive.messaging.kafka.i18n.KafkaLogging_$logger

All Implemented Interfaces:

KafkaLogging, Serializable, org.jboss.logging.BasicLogger

public class KafkaLogging_$logger
extends org.jboss.logging.DelegatingBasicLogger
implements KafkaLogging, org.jboss.logging.BasicLogger, Serializable

Warning this class consists of generated code.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.jboss.logging.DelegatingBasicLogger

log

Fields inherited from interface io.smallrye.reactive.messaging.kafka.i18n.KafkaLogging

log

Constructor Summary

Constructors

Constructor	Description
KafkaLogging_$logger(org.jboss.logging.Logger log)

Method Summary

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

Methods inherited from class org.jboss.logging.DelegatingBasicLogger

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

Constructor Detail

KafkaLogging_$logger

public KafkaLogging_$logger(org.jboss.logging.Logger log)

Method Detail

getLoggingLocale

protected Locale getLoggingLocale()

deadLetterConfig

public final void deadLetterConfig(String deadQueueTopic,
                                   String keySerializer,
                                   String valueSerializer)

Specified by:

deadLetterConfig in interface KafkaLogging

deadLetterConfig$str

protected String deadLetterConfig$str()

messageNackedDeadLetter

public final void messageNackedDeadLetter(String channel,
                                          String topic)

Specified by:

messageNackedDeadLetter in interface KafkaLogging

messageNackedDeadLetter$str

protected String messageNackedDeadLetter$str()

messageNackedFailStop

public final void messageNackedFailStop(String channel)

Specified by:

messageNackedFailStop in interface KafkaLogging

messageNackedFailStop$str

protected String messageNackedFailStop$str()

messageNackedIgnore

public final void messageNackedIgnore(String channel,
                                      String reason)

Specified by:

messageNackedIgnore in interface KafkaLogging

messageNackedIgnore$str

protected String messageNackedIgnore$str()

messageNackedFullIgnored

public final void messageNackedFullIgnored(Throwable t)

Specified by:

messageNackedFullIgnored in interface KafkaLogging

messageNackedFullIgnored$str

protected String messageNackedFullIgnored$str()

unableToWrite

public final void unableToWrite(String channel,
                                String topic,
                                Throwable t)

Specified by:

unableToWrite in interface KafkaLogging

unableToWrite2$str

protected String unableToWrite2$str()

unableToWrite

public final void unableToWrite(String channel,
                                Throwable t)

Specified by:

unableToWrite in interface KafkaLogging

unableToWrite1$str

protected String unableToWrite1$str()

unableToDispatch

public final void unableToDispatch(Throwable t)

Specified by:

unableToDispatch in interface KafkaLogging

unableToDispatch$str

protected String unableToDispatch$str()

sendingMessageToTopic

public final void sendingMessageToTopic(Message message,
                                        String topic)

Specified by:

sendingMessageToTopic in interface KafkaLogging

sendingMessageToTopic$str

protected String sendingMessageToTopic$str()

unableToSendRecord

public final void unableToSendRecord(Throwable t)

Specified by:

unableToSendRecord in interface KafkaLogging

unableToSendRecord$str

protected String unableToSendRecord$str()

successfullyToTopic

public final void successfullyToTopic(Message message,
                                      String topic)

Specified by:

successfullyToTopic in interface KafkaLogging

successfullyToTopic$str

protected String successfullyToTopic$str()

nackingMessage

public final void nackingMessage(Message message,
                                 String topic,
                                 Throwable t)

Specified by:

nackingMessage in interface KafkaLogging

nackingMessage$str

protected String nackingMessage$str()

configServers

public final void configServers(String serverConfig,
                                String servers)

Specified by:

configServers in interface KafkaLogging

configServers$str

protected String configServers$str()

keyDeserializerOmitted

public final void keyDeserializerOmitted()

Specified by:

keyDeserializerOmitted in interface KafkaLogging

keyDeserializerOmitted$str

protected String keyDeserializerOmitted$str()

errorWhileClosingWriteStream

public final void errorWhileClosingWriteStream(Throwable t)

Specified by:

errorWhileClosingWriteStream in interface KafkaLogging

errorWhileClosingWriteStream$str

protected String errorWhileClosingWriteStream$str()

noGroupId

public final void noGroupId(String randomId)

Specified by:

noGroupId in interface KafkaLogging

noGroupId$str

protected String noGroupId$str()

unableToReadRecord

public final void unableToReadRecord(Set<String> topics,
                                     Throwable t)

Specified by:

unableToReadRecord in interface KafkaLogging

unableToReadRecord$str

protected String unableToReadRecord$str()

exceptionOnClose

public final void exceptionOnClose(Throwable t)

Specified by:

exceptionOnClose in interface KafkaLogging

exceptionOnClose$str

protected String exceptionOnClose$str()

loadingConsumerRebalanceListenerFromConfiguredName

public final void loadingConsumerRebalanceListenerFromConfiguredName(String configuredName)

Specified by:

loadingConsumerRebalanceListenerFromConfiguredName in interface KafkaLogging

loadingConsumerRebalanceListenerFromConfiguredName$str

protected String loadingConsumerRebalanceListenerFromConfiguredName$str()

loadingConsumerRebalanceListenerFromGroupId

public final void loadingConsumerRebalanceListenerFromGroupId(String consumerGroup)

Specified by:

loadingConsumerRebalanceListenerFromGroupId in interface KafkaLogging

loadingConsumerRebalanceListenerFromGroupId$str

protected String loadingConsumerRebalanceListenerFromGroupId$str()

unableToExecuteConsumerAssignedRebalanceListener

public final void unableToExecuteConsumerAssignedRebalanceListener(String consumerGroup,
                                                                   Throwable t)

Specified by:

unableToExecuteConsumerAssignedRebalanceListener in interface KafkaLogging

unableToExecuteConsumerAssignedRebalanceListener$str

protected String unableToExecuteConsumerAssignedRebalanceListener$str()

unableToExecuteConsumerRevokedRebalanceListener

public final void unableToExecuteConsumerRevokedRebalanceListener(String consumerGroup,
                                                                  Throwable t)

Specified by:

unableToExecuteConsumerRevokedRebalanceListener in interface KafkaLogging

unableToExecuteConsumerRevokedRebalanceListener$str

protected String unableToExecuteConsumerRevokedRebalanceListener$str()

executingConsumerAssignedRebalanceListener

public final void executingConsumerAssignedRebalanceListener(String consumerGroup)

Specified by:

executingConsumerAssignedRebalanceListener in interface KafkaLogging

executingConsumerAssignedRebalanceListener$str

protected String executingConsumerAssignedRebalanceListener$str()

executingConsumerRevokedRebalanceListener

public final void executingConsumerRevokedRebalanceListener(String consumerGroup)

Specified by:

executingConsumerRevokedRebalanceListener in interface KafkaLogging

executingConsumerRevokedRebalanceListener$str

protected String executingConsumerRevokedRebalanceListener$str()

executedConsumerAssignedRebalanceListener

public final void executedConsumerAssignedRebalanceListener(String consumerGroup)

Specified by:

executedConsumerAssignedRebalanceListener in interface KafkaLogging

executedConsumerAssignedRebalanceListener$str

protected String executedConsumerAssignedRebalanceListener$str()

executedConsumerRevokedRebalanceListener

public final void executedConsumerRevokedRebalanceListener(String consumerGroup)

Specified by:

executedConsumerRevokedRebalanceListener in interface KafkaLogging

executedConsumerRevokedRebalanceListener$str

protected String executedConsumerRevokedRebalanceListener$str()

reEnablingConsumerForGroup

public final void reEnablingConsumerForGroup(String consumerGroup)

Specified by:

reEnablingConsumerForGroup in interface KafkaLogging

reEnablingConsumerForGroup$str

protected String reEnablingConsumerForGroup$str()

failureReported

public final void failureReported(Set<String> topics,
                                  Throwable t)

Specified by:

failureReported in interface KafkaLogging

failureReported$str

protected String failureReported$str()

configuredTopics

public final void configuredTopics(String channel,
                                   Set<String> topics)

Specified by:

configuredTopics in interface KafkaLogging

configuredTopics$str

protected String configuredTopics$str()

configuredPattern

public final void configuredPattern(String channel,
                                    String pattern)

Specified by:

configuredPattern in interface KafkaLogging

configuredPattern$str

protected String configuredPattern$str()

receivedTooManyMessagesWithoutAcking

public final void receivedTooManyMessagesWithoutAcking(String topicPartition,
                                                       long amount)

Specified by:

receivedTooManyMessagesWithoutAcking in interface KafkaLogging

receivedTooManyMessagesWithoutAcking$str

protected String receivedTooManyMessagesWithoutAcking$str()

settingCommitInterval

public final void settingCommitInterval(String group,
                                        long commitInterval)

Specified by:

settingCommitInterval in interface KafkaLogging

settingCommitInterval$str

protected String settingCommitInterval$str()

invalidValueSerializerForStructuredCloudEvent

public final void invalidValueSerializerForStructuredCloudEvent(String serializer)

Specified by:

invalidValueSerializerForStructuredCloudEvent in interface KafkaLogging

invalidValueSerializerForStructuredCloudEvent$str

protected String invalidValueSerializerForStructuredCloudEvent$str()

disableAutoCommit

public final void disableAutoCommit(String channel)

Specified by:

disableAutoCommit in interface KafkaLogging

disableAutoCommit$str

protected String disableAutoCommit$str()

disableThrottledCommitStrategyHealthCheck

public final void disableThrottledCommitStrategyHealthCheck(String group)

Specified by:

disableThrottledCommitStrategyHealthCheck in interface KafkaLogging

disableThrottledCommitStrategyHealthCheck$str

protected String disableThrottledCommitStrategyHealthCheck$str()

setThrottledCommitStrategyReceivedRecordMaxAge

public final void setThrottledCommitStrategyReceivedRecordMaxAge(String group,
                                                                 long unprocessedRecordMaxAge)

Specified by:

setThrottledCommitStrategyReceivedRecordMaxAge in interface KafkaLogging

setThrottledCommitStrategyReceivedRecordMaxAge$str

protected String setThrottledCommitStrategyReceivedRecordMaxAge$str()

setKafkaProducerClientId

public final void setKafkaProducerClientId(String name)

Specified by:

setKafkaProducerClientId in interface KafkaLogging

setKafkaProducerClientId$str

protected String setKafkaProducerClientId$str()

setKafkaConsumerClientId

public final void setKafkaConsumerClientId(String name)

Specified by:

setKafkaConsumerClientId in interface KafkaLogging

setKafkaConsumerClientId$str

protected String setKafkaConsumerClientId$str()

messageAckedForRevokedTopicPartition

public final void messageAckedForRevokedTopicPartition(long offset,
                                                       String groupId,
                                                       String topicPartition)

Specified by:

messageAckedForRevokedTopicPartition in interface KafkaLogging

messageAckedForRevokedTopicPartition$str

protected String messageAckedForRevokedTopicPartition$str()

commitStrategyForChannel

public final void commitStrategyForChannel(String strategy,
                                           String channel)

Specified by:

commitStrategyForChannel in interface KafkaLogging

commitStrategyForChannel$str

protected String commitStrategyForChannel$str()

deserializationFailureHandlerFailure

public final void deserializationFailureHandlerFailure(String instance,
                                                       Throwable t)

Specified by:

deserializationFailureHandlerFailure in interface KafkaLogging

deserializationFailureHandlerFailure$str

protected String deserializationFailureHandlerFailure$str()