Skip to content

Commit 36b67b7

Browse files
committed
Start work on packaging issue dpkp#3
1 parent 036af5b commit 36b67b7

File tree

6 files changed

+16
-3
lines changed

6 files changed

+16
-3
lines changed

kafka/__init__.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
__all__ = ["kafka"]

kafka.py renamed to kafka/kafka.py

File renamed without changes.

setup.py

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
from distutils.core import setup
2+
3+
setup(
4+
name="Kafka Python Client",
5+
version="0.1-alpha",
6+
author="David Arthur",
7+
author_email="mumrah@gmail.com",
8+
url="https://github.com/mumrah/kafka-python",
9+
packages=["kafka"],
10+
license="Copyright 2012, David Arthur under Apache License, v2.0",
11+
long_description=open("README.md").read(),
12+
)

test/__init__.py

Whitespace-only changes.

test/integration.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111
import time
1212
import unittest
1313

14-
from kafka import KafkaClient, ProduceRequest, FetchRequest
14+
from kafka.kafka import KafkaClient, ProduceRequest, FetchRequest
1515

1616
def get_open_port():
1717
sock = socket.socket()

test/unit.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,8 +3,8 @@
33
import struct
44
import unittest
55

6-
from kafka import KafkaClient, ProduceRequest, FetchRequest
7-
from kafka import gzip_encode, gzip_decode, length_prefix_message
6+
from kafka.kafka import KafkaClient, ProduceRequest, FetchRequest
7+
from kafka.kafka import gzip_encode, gzip_decode, length_prefix_message
88

99
ITERATIONS = 1000
1010
STRLEN = 100

0 commit comments

Comments
 (0)