Skip to content

Instantly share code, notes, and snippets.

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 r-ryantm/64567dd9a8b9d7e52e7ab7ae66e063ed to your computer and use it in GitHub Desktop.
Save r-ryantm/64567dd9a8b9d7e52e7ab7ae66e063ed to your computer and use it in GitHub Desktop.
/nix/store/k0yj63rnklqhjsrz4ciznl5m167pibh6-python2.7-kafka-python-2.0.1
├── lib
│   └── python2.7
│   └── site-packages
│   ├── kafka
│   │   ├── admin
│   │   │   ├── acl_resource.py
│   │   │   ├── acl_resource.pyc
│   │   │   ├── client.py
│   │   │   ├── client.pyc
│   │   │   ├── config_resource.py
│   │   │   ├── config_resource.pyc
│   │   │   ├── __init__.py
│   │   │   ├── __init__.pyc
│   │   │   ├── new_partitions.py
│   │   │   ├── new_partitions.pyc
│   │   │   ├── new_topic.py
│   │   │   └── new_topic.pyc
│   │   ├── client_async.py
│   │   ├── client_async.pyc
│   │   ├── cluster.py
│   │   ├── cluster.pyc
│   │   ├── codec.py
│   │   ├── codec.pyc
│   │   ├── conn.py
│   │   ├── conn.pyc
│   │   ├── consumer
│   │   │   ├── fetcher.py
│   │   │   ├── fetcher.pyc
│   │   │   ├── group.py
│   │   │   ├── group.pyc
│   │   │   ├── __init__.py
│   │   │   ├── __init__.pyc
│   │   │   ├── subscription_state.py
│   │   │   └── subscription_state.pyc
│   │   ├── coordinator
│   │   │   ├── assignors
│   │   │   │   ├── abstract.py
│   │   │   │   ├── abstract.pyc
│   │   │   │   ├── __init__.py
│   │   │   │   ├── __init__.pyc
│   │   │   │   ├── range.py
│   │   │   │   ├── range.pyc
│   │   │   │   ├── roundrobin.py
│   │   │   │   └── roundrobin.pyc
│   │   │   ├── base.py
│   │   │   ├── base.pyc
│   │   │   ├── consumer.py
│   │   │   ├── consumer.pyc
│   │   │   ├── heartbeat.py
│   │   │   ├── heartbeat.pyc
│   │   │   ├── __init__.py
│   │   │   ├── __init__.pyc
│   │   │   ├── protocol.py
│   │   │   └── protocol.pyc
│   │   ├── errors.py
│   │   ├── errors.pyc
│   │   ├── future.py
│   │   ├── future.pyc
│   │   ├── __init__.py
│   │   ├── __init__.pyc
│   │   ├── metrics
│   │   │   ├── compound_stat.py
│   │   │   ├── compound_stat.pyc
│   │   │   ├── dict_reporter.py
│   │   │   ├── dict_reporter.pyc
│   │   │   ├── __init__.py
│   │   │   ├── __init__.pyc
│   │   │   ├── kafka_metric.py
│   │   │   ├── kafka_metric.pyc
│   │   │   ├── measurable.py
│   │   │   ├── measurable.pyc
│   │   │   ├── measurable_stat.py
│   │   │   ├── measurable_stat.pyc
│   │   │   ├── metric_config.py
│   │   │   ├── metric_config.pyc
│   │   │   ├── metric_name.py
│   │   │   ├── metric_name.pyc
│   │   │   ├── metrics.py
│   │   │   ├── metrics.pyc
│   │   │   ├── metrics_reporter.py
│   │   │   ├── metrics_reporter.pyc
│   │   │   ├── quota.py
│   │   │   ├── quota.pyc
│   │   │   ├── stat.py
│   │   │   ├── stat.pyc
│   │   │   └── stats
│   │   │   ├── avg.py
│   │   │   ├── avg.pyc
│   │   │   ├── count.py
│   │   │   ├── count.pyc
│   │   │   ├── histogram.py
│   │   │   ├── histogram.pyc
│   │   │   ├── __init__.py
│   │   │   ├── __init__.pyc
│   │   │   ├── max_stat.py
│   │   │   ├── max_stat.pyc
│   │   │   ├── min_stat.py
│   │   │   ├── min_stat.pyc
│   │   │   ├── percentile.py
│   │   │   ├── percentile.pyc
│   │   │   ├── percentiles.py
│   │   │   ├── percentiles.pyc
│   │   │   ├── rate.py
│   │   │   ├── rate.pyc
│   │   │   ├── sampled_stat.py
│   │   │   ├── sampled_stat.pyc
│   │   │   ├── sensor.py
│   │   │   ├── sensor.pyc
│   │   │   ├── total.py
│   │   │   └── total.pyc
│   │   ├── oauth
│   │   │   ├── abstract.py
│   │   │   ├── abstract.pyc
│   │   │   ├── __init__.py
│   │   │   └── __init__.pyc
│   │   ├── partitioner
│   │   │   ├── default.py
│   │   │   ├── default.pyc
│   │   │   ├── __init__.py
│   │   │   └── __init__.pyc
│   │   ├── producer
│   │   │   ├── buffer.py
│   │   │   ├── buffer.pyc
│   │   │   ├── future.py
│   │   │   ├── future.pyc
│   │   │   ├── __init__.py
│   │   │   ├── __init__.pyc
│   │   │   ├── kafka.py
│   │   │   ├── kafka.pyc
│   │   │   ├── record_accumulator.py
│   │   │   ├── record_accumulator.pyc
│   │   │   ├── sender.py
│   │   │   └── sender.pyc
│   │   ├── protocol
│   │   │   ├── abstract.py
│   │   │   ├── abstract.pyc
│   │   │   ├── admin.py
│   │   │   ├── admin.pyc
│   │   │   ├── api.py
│   │   │   ├── api.pyc
│   │   │   ├── commit.py
│   │   │   ├── commit.pyc
│   │   │   ├── fetch.py
│   │   │   ├── fetch.pyc
│   │   │   ├── frame.py
│   │   │   ├── frame.pyc
│   │   │   ├── group.py
│   │   │   ├── group.pyc
│   │   │   ├── __init__.py
│   │   │   ├── __init__.pyc
│   │   │   ├── message.py
│   │   │   ├── message.pyc
│   │   │   ├── metadata.py
│   │   │   ├── metadata.pyc
│   │   │   ├── offset.py
│   │   │   ├── offset.pyc
│   │   │   ├── parser.py
│   │   │   ├── parser.pyc
│   │   │   ├── pickle.py
│   │   │   ├── pickle.pyc
│   │   │   ├── produce.py
│   │   │   ├── produce.pyc
│   │   │   ├── struct.py
│   │   │   ├── struct.pyc
│   │   │   ├── types.py
│   │   │   └── types.pyc
│   │   ├── record
│   │   │   ├── abc.py
│   │   │   ├── abc.pyc
│   │   │   ├── _crc32c.py
│   │   │   ├── _crc32c.pyc
│   │   │   ├── default_records.py
│   │   │   ├── default_records.pyc
│   │   │   ├── __init__.py
│   │   │   ├── __init__.pyc
│   │   │   ├── legacy_records.py
│   │   │   ├── legacy_records.pyc
│   │   │   ├── memory_records.py
│   │   │   ├── memory_records.pyc
│   │   │   ├── util.py
│   │   │   └── util.pyc
│   │   ├── scram.py
│   │   ├── scram.pyc
│   │   ├── serializer
│   │   │   ├── abstract.py
│   │   │   ├── abstract.pyc
│   │   │   ├── __init__.py
│   │   │   └── __init__.pyc
│   │   ├── structs.py
│   │   ├── structs.pyc
│   │   ├── util.py
│   │   ├── util.pyc
│   │   ├── vendor
│   │   │   ├── enum34.py
│   │   │   ├── enum34.pyc
│   │   │   ├── __init__.py
│   │   │   ├── __init__.pyc
│   │   │   ├── selectors34.py
│   │   │   ├── selectors34.pyc
│   │   │   ├── six.py
│   │   │   ├── six.pyc
│   │   │   ├── socketpair.py
│   │   │   └── socketpair.pyc
│   │   ├── version.py
│   │   └── version.pyc
│   └── kafka_python-2.0.1.dist-info
│   ├── INSTALLER
│   ├── LICENSE
│   ├── METADATA
│   ├── RECORD
│   ├── top_level.txt
│   └── WHEEL
└── nix-support
└── propagated-build-inputs
19 directories, 195 files
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment