Skip to content

Commit

Permalink
fix typo
Browse files Browse the repository at this point in the history
  • Loading branch information
root authored and root committed Jan 23, 2025
1 parent a050759 commit ecbe2c2
Show file tree
Hide file tree
Showing 3 changed files with 33 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -3798,7 +3798,7 @@ public DescribeShareGroupsResult describeShareGroups(final Collection<String> gr

@Override
public AlterShareGroupOffsetsResult alterShareGroupOffsets(String groupId, Map<TopicPartition, Long> offsets, AlterShareGroupOffsetsOptions options) {
// TODO support alter share group offset
// TODO support alter share group offsets
throw new InvalidRequestException("The method is not yet implemented");
}

Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,31 @@
package org.apache.kafka.common.requests;

import org.apache.kafka.common.message.AlterShareGroupOffsetsRequestData;
import org.apache.kafka.common.protocol.ApiKeys;
import org.apache.kafka.common.protocol.ByteBufferAccessor;

import java.nio.ByteBuffer;

public class AlterShareGroupOffsetsRequest extends AbstractRequest {

private final AlterShareGroupOffsetsRequestData data;

public AlterShareGroupOffsetsRequest(AlterShareGroupOffsetsRequestData data, short apiVersion) {
super(ApiKeys.ALTER_PARTITION, apiVersion);
this.data = data;
}

@Override
public AlterShareGroupOffsetsRequestData data() {
return data;
}

@Override
public AbstractResponse getErrorResponse(int throttleTimeMs, Throwable e) {
return null;
}

public static AlterShareGroupOffsetsRequest parse(ByteBuffer buffer, short version) {
return new AlterShareGroupOffsetsRequest(new AlterShareGroupOffsetsRequestData(new ByteBufferAccessor(buffer), version), version);
}
}
1 change: 1 addition & 0 deletions core/src/main/scala/kafka/server/KafkaApis.scala
Original file line number Diff line number Diff line change
Expand Up @@ -3192,6 +3192,7 @@ class KafkaApis(val requestChannel: RequestChannel,
}

def handleAlterShareGroupOffsetsRequest(request: RequestChannel.Request): Unit = {
val handleAlterGroupOffsetsRequest = request.body[AlterShareGroupOffsetsRequest]
// TODO: Implement the AlterShareGroupOffsetsRequest handling
}

Expand Down

0 comments on commit ecbe2c2

Please sign in to comment.