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
{{ message }}
This repository was archived by the owner on Mar 24, 2021. It is now read-only.
The docs mention that a Message contains a response_code, topic, payload, key (optional) and offset. However, it seems that in practice, response_code, topic and payload are not present.
In addition, in my first exploration of this library, I assumed the consumers to produce messages of type pykafka.common.Message instead of pykafka.protocol.Message, which are better documented. (pykafka.protocol.Message inherits from pykafka.common.Message, so the missing variables listed above apply here as well.) I would suggest also documenting the type of messages returned by the consumers.
PyKafka version: 2.8.0
The text was updated successfully, but these errors were encountered:
The docs mention that a
Message
contains a response_code, topic, payload, key (optional) and offset. However, it seems that in practice, response_code, topic and payload are not present.In addition, in my first exploration of this library, I assumed the consumers to produce messages of type
pykafka.common.Message
instead ofpykafka.protocol.Message
, which are better documented. (pykafka.protocol.Message
inherits frompykafka.common.Message
, so the missing variables listed above apply here as well.) I would suggest also documenting the type of messages returned by the consumers.PyKafka version: 2.8.0
The text was updated successfully, but these errors were encountered: