Path	Lines of Code
README.md	155
README.rst	164
changelog.rst	84
dependency/readme.txt	12
examples/client/example_async_producer.py	112
examples/client/example_collaborative_consumer.py	66
examples/client/example_general_consumer.py	67
examples/client/example_general_producer.py	81
examples/datahub/basic_example.py	147
examples/datahub/blob/blob_topic_pub.py	64
examples/datahub/blob/blob_topic_sub.py	45
examples/datahub/consume_example.py	76
examples/datahub/tuple/tuple_topic_pub.py	77
examples/datahub/tuple/tuple_topic_sub.py	40
requirements.txt	11
test-requirements.txt	5
tests/fixtures/projects.cursor.topics.invalid_param.shards.0.json	4
tests/fixtures/projects.cursor.topics.success.shards.0.json	5
tests/fixtures/projects.existed.json	4
tests/fixtures/projects.existed.topics.existed.json	4
tests/fixtures/projects.get.topics.blob.shards.0.json	13
tests/fixtures/projects.get.topics.invalid_cursor.shards.0.json	4
tests/fixtures/projects.get.topics.tuple.shards.0.json	22
tests/fixtures/projects.json	7
tests/fixtures/projects.merge.topics.invalid_state.shards.json	4
tests/fixtures/projects.merge.topics.limit_exceeded.shards.json	4
tests/fixtures/projects.merge.topics.shards_not_adjacent.shards.json	4
tests/fixtures/projects.merge.topics.success.shards.json	5
tests/fixtures/projects.meter.topics.success.shards.0.json	4
tests/fixtures/projects.put.topics.invalid_state.shards.json	4
tests/fixtures/projects.put.topics.limit_exceeded.shards.json	4
tests/fixtures/projects.put.topics.malformed.shards.json	4
tests/fixtures/projects.put.topics.success.shards.json	4
tests/fixtures/projects.schema.topics.delete.json	2
tests/fixtures/projects.schema.topics.get.json	6
tests/fixtures/projects.schema.topics.list.json	14
tests/fixtures/projects.schema.topics.register.json	3
tests/fixtures/projects.split.topics.default.shards.json	35
tests/fixtures/projects.split.topics.invalid_key.shards.json	4
tests/fixtures/projects.split.topics.invalid_state.shards.json	4
tests/fixtures/projects.split.topics.limit_exceeded.shards.json	4
tests/fixtures/projects.split.topics.success.shards.json	14
tests/fixtures/projects.success.json	5
tests/fixtures/projects.success.topics.blob.json	8
tests/fixtures/projects.success.topics.json	7
tests/fixtures/projects.success.topics.success.connectors.json	6
tests/fixtures/projects.success.topics.success.shards.json	65
tests/fixtures/projects.success.topics.tuple.json	9
tests/fixtures/projects.unexisted.json	4
tests/fixtures/projects.unexisted.topics.json	4
tests/fixtures/projects.unexisted.topics.valid.connectors.sink_odps.json	4
tests/fixtures/projects.unexisted.topics.valid.json	4
tests/fixtures/projects.unexisted.topics.valid.shards.0.json	4
tests/fixtures/projects.unexisted.topics.valid.shards.json	4
tests/fixtures/projects.valid.topics.unexisted.connectors.sink_odps.json	4
tests/fixtures/projects.valid.topics.unexisted.json	4
tests/fixtures/projects.valid.topics.unexisted.shards.0.json	4
tests/fixtures/projects.valid.topics.unexisted.shards.json	4
tests/fixtures/projects.valid.topics.valid.connectors.sink_odps.json	4
tests/fixtures/projects.valid.topics.valid.shards.0.json	4
tests/fixtures/projects.valid.topics.valid.shards.json	4
tests/fixtures/projects.wait.topics.ready.shards.json	37
tests/fixtures/projects.wait.topics.unready.shards.json	37
tox.ini	23