public class KafkaLogging_$logger extends org.jboss.logging.DelegatingBasicLogger implements KafkaLogging, org.jboss.logging.BasicLogger, Serializable
log| Constructor and Description |
|---|
KafkaLogging_$logger(org.jboss.logging.Logger log) |
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, warnvclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitdebug, 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, warnvprotected Locale getLoggingLocale()
public final void deadLetterConfig(String deadQueueTopic, String keySerializer, String valueSerializer)
deadLetterConfig in interface KafkaLoggingprotected String deadLetterConfig$str()
public final void messageNackedDeadLetter(String channel, String topic)
messageNackedDeadLetter in interface KafkaLoggingprotected String messageNackedDeadLetter$str()
public final void messageNackedFailStop(String channel)
messageNackedFailStop in interface KafkaLoggingprotected String messageNackedFailStop$str()
public final void messageNackedIgnore(String channel, String reason)
messageNackedIgnore in interface KafkaLoggingprotected String messageNackedIgnore$str()
public final void messageNackedFullIgnored(Throwable t)
messageNackedFullIgnored in interface KafkaLoggingprotected String messageNackedFullIgnored$str()
public final void unableToWrite(String channel, String topic, Throwable t)
unableToWrite in interface KafkaLoggingprotected String unableToWrite2$str()
public final void unableToWrite(String channel, Throwable t)
unableToWrite in interface KafkaLoggingprotected String unableToWrite1$str()
public final void unableToDispatch(Throwable t)
unableToDispatch in interface KafkaLoggingprotected String unableToDispatch$str()
public final void sendingMessageToTopic(Message message, String topic)
sendingMessageToTopic in interface KafkaLoggingprotected String sendingMessageToTopic$str()
public final void unableToSendRecord(Throwable t)
unableToSendRecord in interface KafkaLoggingprotected String unableToSendRecord$str()
public final void successfullyToTopic(Message message, String topic)
successfullyToTopic in interface KafkaLoggingprotected String successfullyToTopic$str()
public final void nackingMessage(Message message, String topic, Throwable t)
nackingMessage in interface KafkaLoggingprotected String nackingMessage$str()
public final void configServers(String serverConfig, String servers)
configServers in interface KafkaLoggingprotected String configServers$str()
public final void keyDeserializerOmitted()
keyDeserializerOmitted in interface KafkaLoggingprotected String keyDeserializerOmitted$str()
public final void errorWhileClosingWriteStream(Throwable t)
errorWhileClosingWriteStream in interface KafkaLoggingprotected String errorWhileClosingWriteStream$str()
public final void noGroupId(String randomId)
noGroupId in interface KafkaLoggingprotected String noGroupId$str()
public final void unableToReadRecord(Set<String> topics, Throwable t)
unableToReadRecord in interface KafkaLoggingprotected String unableToReadRecord$str()
public final void exceptionOnClose(Throwable t)
exceptionOnClose in interface KafkaLoggingprotected String exceptionOnClose$str()
public final void loadingConsumerRebalanceListenerFromConfiguredName(String configuredName)
loadingConsumerRebalanceListenerFromConfiguredName in interface KafkaLoggingprotected String loadingConsumerRebalanceListenerFromConfiguredName$str()
public final void loadingConsumerRebalanceListenerFromGroupId(String consumerGroup)
loadingConsumerRebalanceListenerFromGroupId in interface KafkaLoggingprotected String loadingConsumerRebalanceListenerFromGroupId$str()
public final void unableToExecuteConsumerAssignedRebalanceListener(String consumerGroup, Throwable t)
unableToExecuteConsumerAssignedRebalanceListener in interface KafkaLoggingprotected String unableToExecuteConsumerAssignedRebalanceListener$str()
public final void unableToExecuteConsumerRevokedRebalanceListener(String consumerGroup, Throwable t)
unableToExecuteConsumerRevokedRebalanceListener in interface KafkaLoggingprotected String unableToExecuteConsumerRevokedRebalanceListener$str()
public final void executingConsumerAssignedRebalanceListener(String consumerGroup)
executingConsumerAssignedRebalanceListener in interface KafkaLoggingprotected String executingConsumerAssignedRebalanceListener$str()
public final void executingConsumerRevokedRebalanceListener(String consumerGroup)
executingConsumerRevokedRebalanceListener in interface KafkaLoggingprotected String executingConsumerRevokedRebalanceListener$str()
public final void executedConsumerAssignedRebalanceListener(String consumerGroup)
executedConsumerAssignedRebalanceListener in interface KafkaLoggingprotected String executedConsumerAssignedRebalanceListener$str()
public final void executedConsumerRevokedRebalanceListener(String consumerGroup)
executedConsumerRevokedRebalanceListener in interface KafkaLoggingprotected String executedConsumerRevokedRebalanceListener$str()
public final void reEnablingConsumerForGroup(String consumerGroup)
reEnablingConsumerForGroup in interface KafkaLoggingprotected String reEnablingConsumerForGroup$str()
public final void failureReported(Set<String> topics, Throwable t)
failureReported in interface KafkaLoggingprotected String failureReported$str()
public final void failureReportedDuringRebalance(Set<String> topics, Throwable t)
failureReportedDuringRebalance in interface KafkaLoggingprotected String failureReportedDuringRebalance$str()
public final void configuredTopics(String channel, Set<String> topics)
configuredTopics in interface KafkaLoggingprotected String configuredTopics$str()
public final void configuredPattern(String channel, String pattern)
configuredPattern in interface KafkaLoggingprotected String configuredPattern$str()
public final void receivedTooManyMessagesWithoutAcking(String topicPartition, long amount, long lastCommittedOffset)
receivedTooManyMessagesWithoutAcking in interface KafkaLoggingprotected String receivedTooManyMessagesWithoutAcking$str()
public final void settingCommitInterval(String group, long commitInterval)
settingCommitInterval in interface KafkaLoggingprotected String settingCommitInterval$str()
public final void invalidValueSerializerForStructuredCloudEvent(String serializer)
invalidValueSerializerForStructuredCloudEvent in interface KafkaLoggingprotected String invalidValueSerializerForStructuredCloudEvent$str()
public final void disableAutoCommit(String channel)
disableAutoCommit in interface KafkaLoggingprotected String disableAutoCommit$str()
public final void disableThrottledCommitStrategyHealthCheck(String group)
disableThrottledCommitStrategyHealthCheck in interface KafkaLoggingprotected String disableThrottledCommitStrategyHealthCheck$str()
public final void setThrottledCommitStrategyReceivedRecordMaxAge(String group, long unprocessedRecordMaxAge)
setThrottledCommitStrategyReceivedRecordMaxAge in interface KafkaLoggingprotected String setThrottledCommitStrategyReceivedRecordMaxAge$str()
public final void setKafkaProducerClientId(String name)
setKafkaProducerClientId in interface KafkaLoggingprotected String setKafkaProducerClientId$str()
public final void setKafkaConsumerClientId(String name)
setKafkaConsumerClientId in interface KafkaLoggingprotected String setKafkaConsumerClientId$str()
public final void messageAckedForRevokedTopicPartition(long offset,
String groupId,
String topicPartition)
messageAckedForRevokedTopicPartition in interface KafkaLoggingprotected String messageAckedForRevokedTopicPartition$str()
public final void commitStrategyForChannel(String strategy, String channel)
commitStrategyForChannel in interface KafkaLoggingprotected String commitStrategyForChannel$str()
public final void deserializationFailureHandlerFailure(String instance, Throwable t)
deserializationFailureHandlerFailure in interface KafkaLoggingprotected String deserializationFailureHandlerFailure$str()
public final void pauseAllPartitionOnTermination()
pauseAllPartitionOnTermination in interface KafkaLoggingprotected String pauseAllPartitionOnTermination$str()
public final void waitingForMessageProcessing(long p)
waitingForMessageProcessing in interface KafkaLoggingprotected String waitingForMessageProcessing$str()
public final void messageStillUnprocessedAfterTimeout(long unprocessed)
messageStillUnprocessedAfterTimeout in interface KafkaLoggingprotected String messageStillUnprocessedAfterTimeout$str()
public final void pausingChannel(String channel)
pausingChannel in interface KafkaLoggingprotected String pausingChannel$str()
public final void resumingChannel(String channel)
resumingChannel in interface KafkaLoggingprotected String resumingChannel$str()
Copyright © 2018–2021 SmallRye. All rights reserved.