Skip to content

Instantly share code, notes, and snippets.

@ryantm
Created December 14, 2018 21:42
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save ryantm/a1597846448bd7feebc9e8f86981eecb to your computer and use it in GitHub Desktop.
Save ryantm/a1597846448bd7feebc9e8f86981eecb to your computer and use it in GitHub Desktop.
/nix/store/sxyy8djkf2d7d3ag00f2ssvg1rzqhpl1-python3.7-kafka-python-1.4.4
├── lib
│   └── python3.7
│   └── site-packages
│   ├── kafka
│   │   ├── admin
│   │   │   ├── client.py
│   │   │   ├── config_resource.py
│   │   │   ├── __init__.py
│   │   │   ├── new_partitions.py
│   │   │   ├── new_topic.py
│   │   │   └── __pycache__
│   │   │   ├── client.cpython-37.pyc
│   │   │   ├── config_resource.cpython-37.pyc
│   │   │   ├── __init__.cpython-37.pyc
│   │   │   ├── new_partitions.cpython-37.pyc
│   │   │   └── new_topic.cpython-37.pyc
│   │   ├── client_async.py
│   │   ├── client.py
│   │   ├── cluster.py
│   │   ├── codec.py
│   │   ├── common.py
│   │   ├── conn.py
│   │   ├── consumer
│   │   │   ├── base.py
│   │   │   ├── fetcher.py
│   │   │   ├── group.py
│   │   │   ├── __init__.py
│   │   │   ├── multiprocess.py
│   │   │   ├── __pycache__
│   │   │   │   ├── base.cpython-37.pyc
│   │   │   │   ├── fetcher.cpython-37.pyc
│   │   │   │   ├── group.cpython-37.pyc
│   │   │   │   ├── __init__.cpython-37.pyc
│   │   │   │   ├── multiprocess.cpython-37.pyc
│   │   │   │   ├── simple.cpython-37.pyc
│   │   │   │   └── subscription_state.cpython-37.pyc
│   │   │   ├── simple.py
│   │   │   └── subscription_state.py
│   │   ├── context.py
│   │   ├── coordinator
│   │   │   ├── assignors
│   │   │   │   ├── abstract.py
│   │   │   │   ├── __init__.py
│   │   │   │   ├── __pycache__
│   │   │   │   │   ├── abstract.cpython-37.pyc
│   │   │   │   │   ├── __init__.cpython-37.pyc
│   │   │   │   │   ├── range.cpython-37.pyc
│   │   │   │   │   └── roundrobin.cpython-37.pyc
│   │   │   │   ├── range.py
│   │   │   │   └── roundrobin.py
│   │   │   ├── base.py
│   │   │   ├── consumer.py
│   │   │   ├── heartbeat.py
│   │   │   ├── __init__.py
│   │   │   ├── protocol.py
│   │   │   └── __pycache__
│   │   │   ├── base.cpython-37.pyc
│   │   │   ├── consumer.cpython-37.pyc
│   │   │   ├── heartbeat.cpython-37.pyc
│   │   │   ├── __init__.cpython-37.pyc
│   │   │   └── protocol.cpython-37.pyc
│   │   ├── errors.py
│   │   ├── future.py
│   │   ├── __init__.py
│   │   ├── metrics
│   │   │   ├── compound_stat.py
│   │   │   ├── dict_reporter.py
│   │   │   ├── __init__.py
│   │   │   ├── kafka_metric.py
│   │   │   ├── measurable.py
│   │   │   ├── measurable_stat.py
│   │   │   ├── metric_config.py
│   │   │   ├── metric_name.py
│   │   │   ├── metrics.py
│   │   │   ├── metrics_reporter.py
│   │   │   ├── __pycache__
│   │   │   │   ├── compound_stat.cpython-37.pyc
│   │   │   │   ├── dict_reporter.cpython-37.pyc
│   │   │   │   ├── __init__.cpython-37.pyc
│   │   │   │   ├── kafka_metric.cpython-37.pyc
│   │   │   │   ├── measurable.cpython-37.pyc
│   │   │   │   ├── measurable_stat.cpython-37.pyc
│   │   │   │   ├── metric_config.cpython-37.pyc
│   │   │   │   ├── metric_name.cpython-37.pyc
│   │   │   │   ├── metrics.cpython-37.pyc
│   │   │   │   ├── metrics_reporter.cpython-37.pyc
│   │   │   │   ├── quota.cpython-37.pyc
│   │   │   │   └── stat.cpython-37.pyc
│   │   │   ├── quota.py
│   │   │   ├── stat.py
│   │   │   └── stats
│   │   │   ├── avg.py
│   │   │   ├── count.py
│   │   │   ├── histogram.py
│   │   │   ├── __init__.py
│   │   │   ├── max_stat.py
│   │   │   ├── min_stat.py
│   │   │   ├── percentile.py
│   │   │   ├── percentiles.py
│   │   │   ├── __pycache__
│   │   │   │   ├── avg.cpython-37.pyc
│   │   │   │   ├── count.cpython-37.pyc
│   │   │   │   ├── histogram.cpython-37.pyc
│   │   │   │   ├── __init__.cpython-37.pyc
│   │   │   │   ├── max_stat.cpython-37.pyc
│   │   │   │   ├── min_stat.cpython-37.pyc
│   │   │   │   ├── percentile.cpython-37.pyc
│   │   │   │   ├── percentiles.cpython-37.pyc
│   │   │   │   ├── rate.cpython-37.pyc
│   │   │   │   ├── sampled_stat.cpython-37.pyc
│   │   │   │   ├── sensor.cpython-37.pyc
│   │   │   │   └── total.cpython-37.pyc
│   │   │   ├── rate.py
│   │   │   ├── sampled_stat.py
│   │   │   ├── sensor.py
│   │   │   └── total.py
│   │   ├── partitioner
│   │   │   ├── base.py
│   │   │   ├── default.py
│   │   │   ├── hashed.py
│   │   │   ├── __init__.py
│   │   │   ├── __pycache__
│   │   │   │   ├── base.cpython-37.pyc
│   │   │   │   ├── default.cpython-37.pyc
│   │   │   │   ├── hashed.cpython-37.pyc
│   │   │   │   ├── __init__.cpython-37.pyc
│   │   │   │   └── roundrobin.cpython-37.pyc
│   │   │   └── roundrobin.py
│   │   ├── producer
│   │   │   ├── base.py
│   │   │   ├── buffer.py
│   │   │   ├── future.py
│   │   │   ├── __init__.py
│   │   │   ├── kafka.py
│   │   │   ├── keyed.py
│   │   │   ├── __pycache__
│   │   │   │   ├── base.cpython-37.pyc
│   │   │   │   ├── buffer.cpython-37.pyc
│   │   │   │   ├── future.cpython-37.pyc
│   │   │   │   ├── __init__.cpython-37.pyc
│   │   │   │   ├── kafka.cpython-37.pyc
│   │   │   │   ├── keyed.cpython-37.pyc
│   │   │   │   ├── record_accumulator.cpython-37.pyc
│   │   │   │   ├── sender.cpython-37.pyc
│   │   │   │   └── simple.cpython-37.pyc
│   │   │   ├── record_accumulator.py
│   │   │   ├── sender.py
│   │   │   └── simple.py
│   │   ├── protocol
│   │   │   ├── abstract.py
│   │   │   ├── admin.py
│   │   │   ├── api.py
│   │   │   ├── commit.py
│   │   │   ├── fetch.py
│   │   │   ├── frame.py
│   │   │   ├── group.py
│   │   │   ├── __init__.py
│   │   │   ├── legacy.py
│   │   │   ├── message.py
│   │   │   ├── metadata.py
│   │   │   ├── offset.py
│   │   │   ├── parser.py
│   │   │   ├── pickle.py
│   │   │   ├── produce.py
│   │   │   ├── __pycache__
│   │   │   │   ├── abstract.cpython-37.pyc
│   │   │   │   ├── admin.cpython-37.pyc
│   │   │   │   ├── api.cpython-37.pyc
│   │   │   │   ├── commit.cpython-37.pyc
│   │   │   │   ├── fetch.cpython-37.pyc
│   │   │   │   ├── frame.cpython-37.pyc
│   │   │   │   ├── group.cpython-37.pyc
│   │   │   │   ├── __init__.cpython-37.pyc
│   │   │   │   ├── legacy.cpython-37.pyc
│   │   │   │   ├── message.cpython-37.pyc
│   │   │   │   ├── metadata.cpython-37.pyc
│   │   │   │   ├── offset.cpython-37.pyc
│   │   │   │   ├── parser.cpython-37.pyc
│   │   │   │   ├── pickle.cpython-37.pyc
│   │   │   │   ├── produce.cpython-37.pyc
│   │   │   │   ├── struct.cpython-37.pyc
│   │   │   │   └── types.cpython-37.pyc
│   │   │   ├── struct.py
│   │   │   └── types.py
│   │   ├── __pycache__
│   │   │   ├── client_async.cpython-37.pyc
│   │   │   ├── client.cpython-37.pyc
│   │   │   ├── cluster.cpython-37.pyc
│   │   │   ├── codec.cpython-37.pyc
│   │   │   ├── common.cpython-37.pyc
│   │   │   ├── conn.cpython-37.pyc
│   │   │   ├── context.cpython-37.pyc
│   │   │   ├── errors.cpython-37.pyc
│   │   │   ├── future.cpython-37.pyc
│   │   │   ├── __init__.cpython-37.pyc
│   │   │   ├── structs.cpython-37.pyc
│   │   │   ├── util.cpython-37.pyc
│   │   │   └── version.cpython-37.pyc
│   │   ├── record
│   │   │   ├── abc.py
│   │   │   ├── _crc32c.py
│   │   │   ├── default_records.py
│   │   │   ├── __init__.py
│   │   │   ├── legacy_records.py
│   │   │   ├── memory_records.py
│   │   │   ├── __pycache__
│   │   │   │   ├── abc.cpython-37.pyc
│   │   │   │   ├── _crc32c.cpython-37.pyc
│   │   │   │   ├── default_records.cpython-37.pyc
│   │   │   │   ├── __init__.cpython-37.pyc
│   │   │   │   ├── legacy_records.cpython-37.pyc
│   │   │   │   ├── memory_records.cpython-37.pyc
│   │   │   │   └── util.cpython-37.pyc
│   │   │   └── util.py
│   │   ├── serializer
│   │   │   ├── abstract.py
│   │   │   ├── __init__.py
│   │   │   └── __pycache__
│   │   │   ├── abstract.cpython-37.pyc
│   │   │   └── __init__.cpython-37.pyc
│   │   ├── structs.py
│   │   ├── util.py
│   │   ├── vendor
│   │   │   ├── enum34.py
│   │   │   ├── __init__.py
│   │   │   ├── __pycache__
│   │   │   │   ├── enum34.cpython-37.pyc
│   │   │   │   ├── __init__.cpython-37.pyc
│   │   │   │   ├── selectors34.cpython-37.pyc
│   │   │   │   ├── six.cpython-37.pyc
│   │   │   │   └── socketpair.cpython-37.pyc
│   │   │   ├── selectors34.py
│   │   │   ├── six.py
│   │   │   └── socketpair.py
│   │   └── version.py
│   └── kafka_python-1.4.4.dist-info
│   ├── INSTALLER
│   ├── LICENSE
│   ├── METADATA
│   ├── RECORD
│   ├── top_level.txt
│   └── WHEEL
└── nix-support
└── propagated-build-inputs
31 directories, 213 files
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment