diff options
| author | Mark Roberts <wizzat@gmail.com> | 2014-12-16 20:49:13 -0800 |
|---|---|---|
| committer | Mark Roberts <wizzat@gmail.com> | 2014-12-16 20:49:13 -0800 |
| commit | 9c5216a97fde23c2619d3c4d72cab3f912949fbf (patch) | |
| tree | d389018a668db9cb8a5e367edc745b4ddf1ae26d /kafka/common.py | |
| parent | 30c87fb2d7049e27bb5d839791eb36dd790ad152 (diff) | |
| parent | 29cae3e40b1d89d1a21525864794de7de3700461 (diff) | |
| download | kafka-python-9c5216a97fde23c2619d3c4d72cab3f912949fbf.tar.gz | |
Merge pull request #234 from dpkp/high_level_consumer
A simpler kafka consumer
Diffstat (limited to 'kafka/common.py')
| -rw-r--r-- | kafka/common.py | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/kafka/common.py b/kafka/common.py index 008736c..e4b3b1b 100644 --- a/kafka/common.py +++ b/kafka/common.py @@ -63,6 +63,9 @@ Message = namedtuple("Message", TopicAndPartition = namedtuple("TopicAndPartition", ["topic", "partition"]) +KafkaMessage = namedtuple("KafkaMessage", + ["topic", "partition", "offset", "key", "value"]) + ################# # Exceptions # @@ -182,6 +185,10 @@ class ConsumerNoMoreData(KafkaError): pass +class ConsumerTimeout(KafkaError): + pass + + class ProtocolError(KafkaError): pass @@ -190,6 +197,10 @@ class UnsupportedCodecError(KafkaError): pass +class KafkaConfigurationError(KafkaError): + pass + + kafka_errors = { -1 : UnknownError, 0 : NoError, |