Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Consumers with the default group id ("") that use assign(...) to consume from hand-picked partitions will not be able to commit offsets. If they attempt an offset commit they will receive an error. A new error will be introduced in org.apache.kafka.common.protocol.Errors for this purpose.

Code Block
languagejava
titleOffset commit error when standalone consumer commits offsets in a group with id=""
    ...
    ILLEGAL_OFFSET_COMMIT(72, "The standalone consumer belonging to a group with default id (\"\") is not allowed to commit offsets",
        new ApiExceptionBuilder() {
            @Override
            public ApiException build(String message) {
                return new IllegalOffsetCommitException(message);
            }
    }
    ...

Stand-alone consumers using the default group id will have to seek to an offset before start fetching; or the auto.offset.commit value will be used to determine the starting point of fetch. They will no longer be able to start from a previously committed fetch position.

...