You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Mikhail Panchenko (Jira)" <ji...@apache.org> on 2021/04/20 16:36:00 UTC

[jira] [Commented] (KAFKA-12696) Add standard getters to LagInfo class to allow automatic serialization

    [ https://issues.apache.org/jira/browse/KAFKA-12696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325947#comment-17325947 ] 

Mikhail Panchenko commented on KAFKA-12696:
-------------------------------------------

The [contributing docs|https://cwiki.apache.org/confluence/display/KAFKA/Contributing+Code+Changes] say to assign the issue to yourself, but that does not appear possible. I do intend to provide this very simple patch :)

> Add standard getters to LagInfo class to allow automatic serialization
> ----------------------------------------------------------------------
>
>                 Key: KAFKA-12696
>                 URL: https://issues.apache.org/jira/browse/KAFKA-12696
>             Project: Kafka
>          Issue Type: Improvement
>          Components: streams
>            Reporter: Mikhail Panchenko
>            Priority: Trivial
>   Original Estimate: 5m
>  Remaining Estimate: 5m
>
> The LagInfo class has non-standard getters for its member variables. This means that Jackson and other serialization frameworks do not know how to serialize them without additional annotations. So when implementing the sort of system that KAFKA-6144 is meant to enable, as documented here in docs like [Kafka Streams Interactive Queries|https://docs.confluent.io/platform/current/streams/developer-guide/interactive-queries.html#querying-state-stores-during-a-rebalance], one has to either inject a bunch of custom serialization logic into Jersey or wrap this class.
> The patch to fix this is trivial, and I will be putting one up shortly.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)