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	acknowledgementFromRevokedTopicPartition(long offset, org.apache.kafka.common.TopicPartition topicPartition, String groupId, Collection<org.apache.kafka.common.TopicPartition> assignments)
protected String	acknowledgementFromRevokedTopicPartition$str()
void	commitStrategyForChannel(String strategy, String channel)
protected String	commitStrategyForChannel$str()
void	committed(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets)
protected String	committed$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	connectedToKafka(String id, String bootstrapServers, String topic)
void	connectedToKafka(String id, String bootstrapServers, String consumerGroup, Set<String> topics)
protected String	connectedToKafka3$str()
protected String	connectedToKafka4$str()
void	deadLetterConfig(String deadQueueTopic, String keySerializer, String valueSerializer)
protected String	deadLetterConfig$str()
void	deprecatedConfig(String deprecated, String replace)
protected String	deprecatedConfig$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	executingConsumerRevokedRebalanceListener(String consumerGroup)
protected String	executingConsumerRevokedRebalanceListener$str()
void	failedToCommit(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets, Throwable failure)
protected String	failedToCommit$str()
void	failureReported(Set<String> topics, Throwable t)
protected String	failureReported$str()
void	failureReportedDuringRebalance(Set<String> topics, Throwable t)
protected String	failureReportedDuringRebalance$str()
protected Locale	getLoggingLocale()
void	initializeStoreAtPosition(org.apache.kafka.common.TopicPartition topicPartition, long position)
protected String	initializeStoreAtPosition$str()
void	invalidValueSerializerForStructuredCloudEvent(String serializer)
protected String	invalidValueSerializerForStructuredCloudEvent$str()
void	keyDeserializerOmitted()
protected String	keyDeserializerOmitted$str()
void	keySerializerOmitted()
protected String	keySerializerOmitted$str()
void	loadingConsumerRebalanceListenerFromConfiguredName(String configuredName)
protected String	loadingConsumerRebalanceListenerFromConfiguredName$str()
void	loadingConsumerRebalanceListenerFromGroupId(String consumerGroup)
protected String	loadingConsumerRebalanceListenerFromGroupId$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	messageStillUnprocessedAfterTimeout(long unprocessed)
protected String	messageStillUnprocessedAfterTimeout$str()
void	nackingMessage(Message<?> message, String topic, Throwable t)
protected String	nackingMessage$str()
void	noGroupId(String randomId)
protected String	noGroupId$str()
void	partitionRevokedCollectingRecordsToCommit(org.apache.kafka.common.TopicPartition partition, long commit)
protected String	partitionRevokedCollectingRecordsToCommit$str()
void	pauseAllPartitionOnTermination()
protected String	pauseAllPartitionOnTermination$str()
void	pausingChannel(String channel, int queueSize, int maxQueueSize)
protected String	pausingChannel$str()
void	receivedOutdatedOffset(org.apache.kafka.common.TopicPartition topicPartition, long offset, long lastCommitted)
protected String	receivedOutdatedOffset$str()
void	reEnablingConsumerForGroup(String consumerGroup)
protected String	reEnablingConsumerForGroup$str()
void	removingPartitionFromStore(org.apache.kafka.common.TopicPartition tp, Collection<org.apache.kafka.common.TopicPartition> assignments)
protected String	removingPartitionFromStore$str()
void	resumingChannel(String channel, int queueSize, int halfMaxQueueSize)
protected String	resumingChannel$str()
void	sendingMessageToTopic(Message<?> message, String topic)
protected String	sendingMessageToTopic$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	unableToDeserializeMessage(String topic, Throwable t)
protected String	unableToDeserializeMessage$str()
void	unableToDispatch(Throwable t)
protected String	unableToDispatch$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()
void	waitingForAckForTooLong(long offset, org.apache.kafka.common.TopicPartition topicPartition, long delay, long configInMs, long queueSize, long lastCommittedOffset)
protected String	waitingForAckForTooLong$str()
void	waitingForMessageProcessing(long p)
protected String	waitingForMessageProcessing$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()

unableToExecuteConsumerRevokedRebalanceListener

public final void unableToExecuteConsumerRevokedRebalanceListener(String consumerGroup,
                                                                  Throwable t)

Specified by:

unableToExecuteConsumerRevokedRebalanceListener in interface KafkaLogging

unableToExecuteConsumerRevokedRebalanceListener$str

protected String unableToExecuteConsumerRevokedRebalanceListener$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()

failureReportedDuringRebalance

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

Specified by:

failureReportedDuringRebalance in interface KafkaLogging

failureReportedDuringRebalance$str

protected String failureReportedDuringRebalance$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()

waitingForAckForTooLong

public final void waitingForAckForTooLong(long offset,
                                          org.apache.kafka.common.TopicPartition topicPartition,
                                          long delay,
                                          long configInMs,
                                          long queueSize,
                                          long lastCommittedOffset)

Specified by:

waitingForAckForTooLong in interface KafkaLogging

waitingForAckForTooLong$str

protected String waitingForAckForTooLong$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()

acknowledgementFromRevokedTopicPartition

public final void acknowledgementFromRevokedTopicPartition(long offset,
                                                           org.apache.kafka.common.TopicPartition topicPartition,
                                                           String groupId,
                                                           Collection<org.apache.kafka.common.TopicPartition> assignments)

Specified by:

acknowledgementFromRevokedTopicPartition in interface KafkaLogging

acknowledgementFromRevokedTopicPartition$str

protected String acknowledgementFromRevokedTopicPartition$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()

pauseAllPartitionOnTermination

public final void pauseAllPartitionOnTermination()

Specified by:

pauseAllPartitionOnTermination in interface KafkaLogging

pauseAllPartitionOnTermination$str

protected String pauseAllPartitionOnTermination$str()

waitingForMessageProcessing

public final void waitingForMessageProcessing(long p)

Specified by:

waitingForMessageProcessing in interface KafkaLogging

waitingForMessageProcessing$str

protected String waitingForMessageProcessing$str()

messageStillUnprocessedAfterTimeout

public final void messageStillUnprocessedAfterTimeout(long unprocessed)

Specified by:

messageStillUnprocessedAfterTimeout in interface KafkaLogging

messageStillUnprocessedAfterTimeout$str

protected String messageStillUnprocessedAfterTimeout$str()

pausingChannel

public final void pausingChannel(String channel,
                                 int queueSize,
                                 int maxQueueSize)

Specified by:

pausingChannel in interface KafkaLogging

pausingChannel$str

protected String pausingChannel$str()

resumingChannel

public final void resumingChannel(String channel,
                                  int queueSize,
                                  int halfMaxQueueSize)

Specified by:

resumingChannel in interface KafkaLogging

resumingChannel$str

protected String resumingChannel$str()

keySerializerOmitted

public final void keySerializerOmitted()

Specified by:

keySerializerOmitted in interface KafkaLogging

keySerializerOmitted$str

protected String keySerializerOmitted$str()

unableToDeserializeMessage

public final void unableToDeserializeMessage(String topic,
                                             Throwable t)

Specified by:

unableToDeserializeMessage in interface KafkaLogging

unableToDeserializeMessage$str

protected String unableToDeserializeMessage$str()

deprecatedConfig

public final void deprecatedConfig(String deprecated,
                                   String replace)

Specified by:

deprecatedConfig in interface KafkaLogging

deprecatedConfig$str

protected String deprecatedConfig$str()

committed

public final void committed(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets)

Specified by:

committed in interface KafkaLogging

committed$str

protected String committed$str()

failedToCommit

public final void failedToCommit(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets,
                                 Throwable failure)

Specified by:

failedToCommit in interface KafkaLogging

failedToCommit$str

protected String failedToCommit$str()

removingPartitionFromStore

public final void removingPartitionFromStore(org.apache.kafka.common.TopicPartition tp,
                                             Collection<org.apache.kafka.common.TopicPartition> assignments)

Specified by:

removingPartitionFromStore in interface KafkaLogging

removingPartitionFromStore$str

protected String removingPartitionFromStore$str()

partitionRevokedCollectingRecordsToCommit

public final void partitionRevokedCollectingRecordsToCommit(org.apache.kafka.common.TopicPartition partition,
                                                            long commit)

Specified by:

partitionRevokedCollectingRecordsToCommit in interface KafkaLogging

partitionRevokedCollectingRecordsToCommit$str

protected String partitionRevokedCollectingRecordsToCommit$str()

receivedOutdatedOffset

public final void receivedOutdatedOffset(org.apache.kafka.common.TopicPartition topicPartition,
                                         long offset,
                                         long lastCommitted)

Specified by:

receivedOutdatedOffset in interface KafkaLogging

receivedOutdatedOffset$str

protected String receivedOutdatedOffset$str()

initializeStoreAtPosition

public final void initializeStoreAtPosition(org.apache.kafka.common.TopicPartition topicPartition,
                                            long position)

Specified by:

initializeStoreAtPosition in interface KafkaLogging

initializeStoreAtPosition$str

protected String initializeStoreAtPosition$str()

connectedToKafka

public final void connectedToKafka(String id,
                                   String bootstrapServers,
                                   String consumerGroup,
                                   Set<String> topics)

Specified by:

connectedToKafka in interface KafkaLogging

connectedToKafka4$str

protected String connectedToKafka4$str()

connectedToKafka

public final void connectedToKafka(String id,
                                   String bootstrapServers,
                                   String topic)

Specified by:

connectedToKafka in interface KafkaLogging

connectedToKafka3$str

protected String connectedToKafka3$str()