Path	Lines of Code
MANIFEST.in	4
benchmarks/perf_get_records.py	69
benchmarks/perf_put_records.py	87
datahub/__init__.py	5
datahub/auth/__init__.py	3
datahub/auth/aliyun_account.py	73
datahub/auth/core.py	10
datahub/batch/__init__.py	1
datahub/batch/batch_binary_record.py	65
datahub/batch/batch_header.py	78
datahub/batch/batch_serializer.py	86
datahub/batch/binary_record.py	203
datahub/batch/record_header.py	51
datahub/batch/schema_registry_client.py	77
datahub/batch/utils.py	48
datahub/client/__init__.py	4
datahub/client/common/__init__.py	1
datahub/client/common/config.py	148
datahub/client/common/constant.py	32
datahub/client/common/datahub_factory.py	21
datahub/client/common/library_factory.py	24
datahub/client/common/meta_data.py	130
datahub/client/common/offset_meta.py	45
datahub/client/common/shard_coordinator.py	77
datahub/client/common/thread_pool.py	126
datahub/client/common/timer.py	48
datahub/client/consumer/__init__.py	1
datahub/client/consumer/consumer_coordinator.py	129
datahub/client/consumer/consumer_heartbeat.py	105
datahub/client/consumer/datahub_consumer.py	23
datahub/client/consumer/message_key.py	18
datahub/client/consumer/message_reader.py	75
datahub/client/consumer/offset_coordinator.py	78
datahub/client/consumer/offset_manager.py	173
datahub/client/consumer/offset_select_strategy.py	39
datahub/client/consumer/shard_group_reader.py	136
datahub/client/consumer/shard_reader.py	165
datahub/client/consumer/sync_group_meta.py	33
datahub/client/producer/__init__.py	1
datahub/client/producer/datahub_producer.py	26
datahub/client/producer/message_writer.py	36
datahub/client/producer/record_pack.py	46
datahub/client/producer/record_pack_queue.py	36
datahub/client/producer/shard_group_writer.py	135
datahub/client/producer/shard_writer.py	114
datahub/client/producer/write_result.py	14
datahub/core.py	185
datahub/exceptions.py	84
datahub/implement.py	672
datahub/models/__init__.py	11
datahub/models/compress.py	84
datahub/models/connector.py	786
datahub/models/cursor.py	7
datahub/models/params.py	881
datahub/models/record.py	344
datahub/models/results.py	1042
datahub/models/schema.py	142
datahub/models/shard.py	147
datahub/models/subscription.py	175
datahub/models/types.py	229
datahub/proto/__init__.py	1
datahub/proto/datahub_record_proto_pb.py	53
datahub/proto/record.proto	80
datahub/rest.py	248
datahub/utils/__init__.py	4
datahub/utils/codec.py	26
datahub/utils/constants.py	14
datahub/utils/converters.py	33
datahub/utils/validator.py	57
datahub/version.py	2
readthedocs.yaml	13
setup.py	37