Skip to content

Fix consumerOffset deserialization compatibility#10283

Open
zhishengzhang wants to merge 1 commit intoapache:developfrom
zhishengzhang:fix/consumerOffset-unquoted-key-compatibility
Open

Fix consumerOffset deserialization compatibility#10283
zhishengzhang wants to merge 1 commit intoapache:developfrom
zhishengzhang:fix/consumerOffset-unquoted-key-compatibility

Conversation

@zhishengzhang
Copy link
Copy Markdown

between 5.4.x and 5.5.x

When upgrading from 5.4.x to 5.5.x

Which Issue(s) This PR Fixes

  • Fixes #issue_id

Brief Description

How Did You Test This Change?

between 5.4.x and 5.5.x

When upgrading from 5.4.x to 5.5.x
Map topicOffsets = (Map) offsetTable.get("TopicTest@gid-test");
assertNotNull(topicOffsets);

assertEquals(123L, ((Number) topicOffsets.get("0")).longValue());
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Could you clarify why get("0") is used here? consumerOffset uses Integer queueId keys, and get(0) works.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants