Class OffsetCommitExceptionLogger

java.lang.Object

io.micronaut.configuration.kafka.exceptions.OffsetCommitExceptionLogger

@Internal
public final class OffsetCommitExceptionLogger
extends Object

Helper for handling Kafka offset commit failures that can be expected during cooperative rebalancing.

Since:

5.4

Method Summary

Modifier and Type	Method	Description
static boolean	isCooperativeStickyAssignor(@Nullable Object assignmentStrategy)
static void	log(org.slf4j.Logger logger, boolean cooperativeStickyAssignmentStrategy, String message, Throwable exception, Object... arguments)
static boolean	shouldLogAtWarn(boolean cooperativeStickyAssignmentStrategy, @Nullable Throwable exception)

Methods inherited from class Object

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

Method Details

isCooperativeStickyAssignor

public static boolean isCooperativeStickyAssignor(@Nullable
 @Nullable Object assignmentStrategy)

shouldLogAtWarn

public static boolean shouldLogAtWarn(boolean cooperativeStickyAssignmentStrategy,
 @Nullable
 @Nullable Throwable exception)

log

public static void log(org.slf4j.Logger logger,
 boolean cooperativeStickyAssignmentStrategy,
 String message,
 Throwable exception,
 Object... arguments)