[
https://issues.apache.org/jira/browse/KAFKA-18201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17905776#comment-17905776
]
PoAn Yang commented on KAFKA-18201:
-----------------------------------
Hi [~lianetm], I found that GroupMetadataValue is only for classic consumer.
For async consumer, it has many different kind of record value like
ConsumerGroupRegularExpressionValue, ConsumerGroupCurrentMemberAssignmentValue,
etc.
We can update GroupMetadataValue to fulfill async consumer. However, the
difficult part is that all coordinator record value version is 0. We need to
use key version to know what type of value is. That means we may need to update
ApiMessageFormatter#writeTo function to pass key version when decoding the
value.
> testGroupMetadataMessageFormatter fails for new consumer protocol
> -----------------------------------------------------------------
>
> Key: KAFKA-18201
> URL: https://issues.apache.org/jira/browse/KAFKA-18201
> Project: Kafka
> Issue Type: Bug
> Reporter: Lianet Magrans
> Assignee: PoAn Yang
> Priority: Major
>
> This fails when the new protocol/consumer are used, with
> java.lang.NullPointerException: Cannot invoke
> "com.fasterxml.jackson.databind.JsonNode.get(String)" because "keyNode" is
> null
> Not sure if it's a bug that needs fixing or if the test needs to be updated
> to successfully run with group.protocol=CONSUMER
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
