You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Currently the API exposes the statistics callback from rdkafka and provides the full JSON string. As far as I could see, there is no function to parse this into a structured representation. It would be nice to have e.g. an aeson parser for the statistics json.
I am going to implement one for myself anyway to monitor consumer lag, but I was wondering if you would be interested in a PR? Personally I am a bit torn if it should be added to this library. It feels like crucial functionality for using Kafka in production, on the other hand aeson is not a terribly light-weight dependency....
The text was updated successfully, but these errors were encountered:
Currently the API exposes the statistics callback from rdkafka and provides the full JSON string. As far as I could see, there is no function to parse this into a structured representation. It would be nice to have e.g. an aeson parser for the statistics json.
I am going to implement one for myself anyway to monitor consumer lag, but I was wondering if you would be interested in a PR? Personally I am a bit torn if it should be added to this library. It feels like crucial functionality for using Kafka in production, on the other hand aeson is not a terribly light-weight dependency....
The text was updated successfully, but these errors were encountered: