Parsely/pykafka

Documentation regarding Message

Open

#917 opened on Feb 13, 2019

View on GitHub
 (1 comment) (0 reactions) (0 assignees)Python (231 forks)batch import
documentationhelp wanted

Repository metrics

Stars
 (1,114 stars)
PR merge metrics
 (No merged PRs in 30d)

Description

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

Contributor guide