path # lines of code # active days days since first update days since last update # commits # contributors first updated last updated first contributor last contributor benchmarks/perf_get_records.py 69 1 1381 1381 1 1 2021-08-04 2021-08-04 uv747@163.com uv747@163.com datahub/rest.py 248 5 1831 472 5 4 2020-05-11 2024-01-30 534815812@qq.com panjinxing.pjx@alibaba-inc.com datahub/utils/validator.py 57 1 1831 1831 1 1 2020-05-11 2020-05-11 534815812@qq.com 534815812@qq.com datahub/utils/codec.py 26 1 1831 1831 1 1 2020-05-11 2020-05-11 534815812@qq.com 534815812@qq.com datahub/models/types.py 229 6 1831 72 6 3 2020-05-11 2025-03-05 534815812@qq.com panjinxing.pjx@alibaba-inc.com datahub/models/__init__.py 11 2 2249 645 2 2 2019-03-20 2023-08-10 534815812@qq.com panjinxing.pjx@alibaba-inc.com datahub/models/connector.py 786 4 2249 814 4 3 2019-03-20 2023-02-22 534815812@qq.com lewei@b-w2ppmd6p-0004.local datahub/models/results.py 1042 4 1831 473 4 4 2020-05-11 2024-01-29 534815812@qq.com panjinxing.pjx@alibaba-inc.com datahub/models/params.py 881 7 2249 473 8 5 2019-03-20 2024-01-29 534815812@qq.com panjinxing.pjx@alibaba-inc.com datahub/models/compress.py 84 1 799 799 1 1 2023-03-09 2023-03-09 lewei@b-w2ppmd6p-0004.local lewei@b-w2ppmd6p-0004.local datahub/models/schema.py 142 2 1381 757 2 2 2021-08-04 2023-04-20 uv747@163.com lewei@b-w2ppmd6p-0004.local datahub/models/record.py 344 3 1831 799 3 3 2020-05-11 2023-03-09 534815812@qq.com lewei@b-w2ppmd6p-0004.local datahub/models/subscription.py 175 1 799 799 1 1 2023-03-09 2023-03-09 lewei@b-w2ppmd6p-0004.local lewei@b-w2ppmd6p-0004.local datahub/__init__.py 5 2 799 473 2 2 2023-03-09 2024-01-29 lewei@b-w2ppmd6p-0004.local panjinxing.pjx@alibaba-inc.com datahub/implement.py 672 8 2249 473 9 5 2019-03-20 2024-01-29 534815812@qq.com panjinxing.pjx@alibaba-inc.com datahub/batch/schema_registry_client.py 77 2 799 529 2 2 2023-03-09 2023-12-04 lewei@b-w2ppmd6p-0004.local panjinxing.pjx@alibaba-inc.com datahub/batch/batch_header.py 78 2 799 529 2 2 2023-03-09 2023-12-04 lewei@b-w2ppmd6p-0004.local panjinxing.pjx@alibaba-inc.com datahub/batch/__init__.py 1 2 799 529 2 2 2023-03-09 2023-12-04 lewei@b-w2ppmd6p-0004.local panjinxing.pjx@alibaba-inc.com datahub/batch/batch_serializer.py 86 2 799 529 2 2 2023-03-09 2023-12-04 lewei@b-w2ppmd6p-0004.local panjinxing.pjx@alibaba-inc.com datahub/batch/record_header.py 51 2 799 529 2 2 2023-03-09 2023-12-04 lewei@b-w2ppmd6p-0004.local panjinxing.pjx@alibaba-inc.com datahub/batch/binary_record.py 203 2 799 529 2 2 2023-03-09 2023-12-04 lewei@b-w2ppmd6p-0004.local panjinxing.pjx@alibaba-inc.com datahub/batch/utils.py 48 2 799 529 2 2 2023-03-09 2023-12-04 lewei@b-w2ppmd6p-0004.local panjinxing.pjx@alibaba-inc.com datahub/batch/batch_binary_record.py 65 2 799 529 2 2 2023-03-09 2023-12-04 lewei@b-w2ppmd6p-0004.local panjinxing.pjx@alibaba-inc.com datahub/exceptions.py 84 3 1831 529 3 3 2020-05-11 2023-12-04 534815812@qq.com panjinxing.pjx@alibaba-inc.com datahub/client/common/meta_data.py 130 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/common/constant.py 32 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/common/__init__.py 1 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/common/timer.py 48 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/common/thread_pool.py 126 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/common/config.py 148 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/common/offset_meta.py 45 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/common/shard_coordinator.py 77 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/common/library_factory.py 24 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/common/datahub_factory.py 21 2 473 472 2 1 2024-01-29 2024-01-30 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/__init__.py 4 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/consumer/consumer_heartbeat.py 105 2 473 273 2 1 2024-01-29 2024-08-16 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/consumer/consumer_coordinator.py 129 2 473 273 2 1 2024-01-29 2024-08-16 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/consumer/message_reader.py 75 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/consumer/__init__.py 1 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/consumer/offset_select_strategy.py 39 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/consumer/shard_group_reader.py 136 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/consumer/offset_coordinator.py 78 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/consumer/shard_reader.py 165 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/consumer/offset_manager.py 173 2 473 189 2 1 2024-01-29 2024-11-08 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/consumer/message_key.py 18 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/consumer/datahub_consumer.py 23 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/consumer/sync_group_meta.py 33 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/producer/datahub_producer.py 26 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/producer/__init__.py 1 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/producer/record_pack_queue.py 36 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/producer/shard_group_writer.py 135 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/producer/record_pack.py 46 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/producer/message_writer.py 36 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/producer/write_result.py 14 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/client/producer/shard_writer.py 114 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com datahub/core.py 185 8 2249 470 9 5 2019-03-20 2024-02-01 534815812@qq.com panjinxing.pjx@alibaba-inc.com datahub/version.py 2 19 2249 189 19 5 2019-03-20 2024-11-08 534815812@qq.com panjinxing.pjx@alibaba-inc.com datahub/proto/record.proto 80 1 799 799 1 1 2023-03-09 2023-03-09 lewei@b-w2ppmd6p-0004.local lewei@b-w2ppmd6p-0004.local datahub/proto/datahub_record_proto_pb.py 53 1 799 799 1 1 2023-03-09 2023-03-09 lewei@b-w2ppmd6p-0004.local lewei@b-w2ppmd6p-0004.local datahub/auth/aliyun_account.py 73 1 858 858 1 1 2023-01-09 2023-01-09 lewei@b-w2ppmd6p-0004.local lewei@b-w2ppmd6p-0004.local setup.py 37 1 473 473 1 1 2024-01-29 2024-01-29 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com readthedocs.yaml 13 2 469 467 10 1 2024-02-02 2024-02-04 panjinxing.pjx@alibaba-inc.com panjinxing.pjx@alibaba-inc.com