Skip to content
This repository has been archived by the owner on Jan 24, 2024. It is now read-only.

[BUGFIX] Remove duplicated call skipBrokerEntryMetadataIfExist when parseMessageMetadata #767

Merged
merged 1 commit into from
Sep 30, 2021
Merged

[BUGFIX] Remove duplicated call skipBrokerEntryMetadataIfExist when parseMessageMetadata #767

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
1 change: 0 additions & 1 deletion ...a-impl/src/main/java/io/streamnative/pulsar/handlers/kop/format/PulsarEntryFormatter.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -111,7 +111,6 @@ public DecodeResult decode(final List<Entry> entries, final byte magic) {
// each entry is a batched message
ByteBuf metadataAndPayload = entry.getDataBuffer();

Commands.skipBrokerEntryMetadataIfExist(metadataAndPayload);
MessageMetadata msgMetadata = Commands.parseMessageMetadata(metadataAndPayload);

decodeResults.add(ByteBufUtils.decodePulsarEntryToKafkaRecords(
Expand Down
1 change: 0 additions & 1 deletion kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/utils/MessageIdUtils.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,6 @@ public static long getLogEndOffset(ManagedLedger managedLedger) {

public static long getPublishTime(final ByteBuf byteBuf) {
final int readerIndex = byteBuf.readerIndex();
Commands.skipBrokerEntryMetadataIfExist(byteBuf);
final MessageMetadata metadata = Commands.parseMessageMetadata(byteBuf);
byteBuf.readerIndex(readerIndex);
return metadata.getPublishTime();
Expand Down