From 0678a452ca7ad5fba8e947cbfcf8fcb0f87b902c Mon Sep 17 00:00:00 2001
From: David Arthur <mumrah@gmail.com>
Date: Mon, 1 Apr 2013 14:56:59 -0400
Subject: Refactoring a bit, cleanup for 0.8

Marking some stuff as not compatible for 0.8 (will be added in 0.8.1)
---
 kafka/queue.py | 2 ++
 1 file changed, 2 insertions(+)

(limited to 'kafka/queue.py')

diff --git a/kafka/queue.py b/kafka/queue.py
index d4f5b6c..6fe9eaa 100644
--- a/kafka/queue.py
+++ b/kafka/queue.py
@@ -8,6 +8,8 @@ from .client import KafkaClient, FetchRequest, ProduceRequest
 
 log = logging.getLogger("kafka")
 
+raise NotImplementedError("Still need to refactor this class")
+
 class KafkaConsumerProcess(Process):
     def __init__(self, client, topic, partition, out_queue, barrier, consumer_fetch_size=1024, consumer_sleep=200):
         self.client = copy(client)
-- 
cgit v1.2.1