Class ConsumerGroupOffsetsUtils

java.lang.Object

io.confluent.kafkarest.exceptions.ConsumerGroupOffsetsUtils

public final class ConsumerGroupOffsetsUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ConsumerGroupOffsetsUtils.Error

Field Summary

Fields

Modifier and Type	Field	Description
static final String	BAD_REQUEST_ERROR_MSG_ALTER_OFFSETS_TMPL
static final String	GROUP_UNAUTHORIZED_ERROR_MSG_ALTER_OFFSETS_TMPL
static final String	INTERNAL_SERVER_ERROR_MSG_ALTER_OFFSETS_TMPL
static final String	INTERNAL_SERVER_ERROR_MSG_LIST_OFFSETS_TMPL
static final String	TOPIC_UNAUTHORIZED_ERROR_MSG_ALTER_OFFSETS_TMPL
static final String	UNAUTHORIZED_ERROR_MSG_ALTER_OFFSETS_TMPL
static final String	UNAUTHORIZED_ERROR_MSG_LIST_OFFSETS_TMPL

Method Summary

Modifier and Type	Method	Description
static ConsumerGroupOffsetsUtils.Error	mapAlterOffsetExecutionExceptionToError(ExecutionException ee, org.apache.kafka.common.TopicPartition tp, String consumerGroupId)	Maps ExecutionException, thrown while handling result of Admin.alterConsumerGroupOffsets(), to REST errors.
static ConsumerGroupOffsetsUtils.Error	mapListOffsetExecutionExceptionToError(ExecutionException ee, org.apache.kafka.common.TopicPartition tp, String consumerGroupId)	Maps ExecutionException, thrown while handling result of Admin.ListOffsets(), to REST errors.

Methods inherited from class java.lang.Object

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

Field Details

INTERNAL_SERVER_ERROR_MSG_LIST_OFFSETS_TMPL

public static final String INTERNAL_SERVER_ERROR_MSG_LIST_OFFSETS_TMPL

See Also:

• Constant Field Values

INTERNAL_SERVER_ERROR_MSG_ALTER_OFFSETS_TMPL

public static final String INTERNAL_SERVER_ERROR_MSG_ALTER_OFFSETS_TMPL

See Also:

• Constant Field Values

UNAUTHORIZED_ERROR_MSG_LIST_OFFSETS_TMPL

public static final String UNAUTHORIZED_ERROR_MSG_LIST_OFFSETS_TMPL

See Also:

• Constant Field Values

UNAUTHORIZED_ERROR_MSG_ALTER_OFFSETS_TMPL

public static final String UNAUTHORIZED_ERROR_MSG_ALTER_OFFSETS_TMPL

See Also:

• Constant Field Values

GROUP_UNAUTHORIZED_ERROR_MSG_ALTER_OFFSETS_TMPL

public static final String GROUP_UNAUTHORIZED_ERROR_MSG_ALTER_OFFSETS_TMPL

See Also:

• Constant Field Values

TOPIC_UNAUTHORIZED_ERROR_MSG_ALTER_OFFSETS_TMPL

public static final String TOPIC_UNAUTHORIZED_ERROR_MSG_ALTER_OFFSETS_TMPL

See Also:

• Constant Field Values

BAD_REQUEST_ERROR_MSG_ALTER_OFFSETS_TMPL

public static final String BAD_REQUEST_ERROR_MSG_ALTER_OFFSETS_TMPL

See Also:

• Constant Field Values

Method Details

mapListOffsetExecutionExceptionToError

public static ConsumerGroupOffsetsUtils.Error mapListOffsetExecutionExceptionToError(ExecutionException ee,
 org.apache.kafka.common.TopicPartition tp,
 String consumerGroupId)

Maps ExecutionException, thrown while handling result of Admin.ListOffsets(), to REST errors.

mapAlterOffsetExecutionExceptionToError

public static ConsumerGroupOffsetsUtils.Error mapAlterOffsetExecutionExceptionToError(ExecutionException ee,
 org.apache.kafka.common.TopicPartition tp,
 String consumerGroupId)

Maps ExecutionException, thrown while handling result of Admin.alterConsumerGroupOffsets(), to REST errors.