diff options
| -rw-r--r-- | .gitignore | 1 | ||||
| -rw-r--r-- | python-kafka-utils.spec | 265 | ||||
| -rw-r--r-- | sources | 1 |
3 files changed, 267 insertions, 0 deletions
@@ -0,0 +1 @@ +/kafka-utils-4.1.0.tar.gz diff --git a/python-kafka-utils.spec b/python-kafka-utils.spec new file mode 100644 index 0000000..78c2ee1 --- /dev/null +++ b/python-kafka-utils.spec @@ -0,0 +1,265 @@ +%global _empty_manifest_terminate_build 0 +Name: python-kafka-utils +Version: 4.1.0 +Release: 1 +Summary: Kafka management utils +License: Apache License 2.0 +URL: https://github.com/Yelp/kafka-utils +Source0: https://mirrors.nju.edu.cn/pypi/web/packages/96/cd/7db60eb657771b79673e4bc6ad9882fedf8a0604134ef91838b7a6e463b9/kafka-utils-4.1.0.tar.gz +BuildArch: noarch + +Requires: python3-humanfriendly +Requires: python3-kafka-python +Requires: python3-kazoo +Requires: python3-PyYAML +Requires: python3-pytz +Requires: python3-requests-futures +Requires: python3-paramiko +Requires: python3-requests +Requires: python3-tenacity +Requires: python3-typing-extensions + +%description + clusters: + cluster-1: + broker_list: + - "cluster-elb-1:9092" + zookeeper: "11.11.11.111:2181,11.11.11.112:2181,11.11.11.113:2181/kafka-1" + cluster-2: + broker_list: + - "cluster-elb-2:9092" + zookeeper: "11.11.11.211:2181,11.11.11.212:2181,11.11.11.213:2181/kafka-2" + local_config: + cluster: cluster-1 +``` +## Install +From PyPI: +```shell + $ pip install kafka-utils +``` +## Kafka-Utils command-line interface +### List all clusters +```shell + $ kafka-utils + cluster-type sample_type: + cluster-name: cluster-1 + broker-list: cluster-elb-1:9092 + zookeeper: 11.11.11.111:2181,11.11.11.112:2181,11.11.11.113:2181/kafka-1 + cluster-name: cluster-2 + broker-list: cluster-elb-2:9092 + zookeeper: 11.11.11.211:2181,11.11.11.212:2181,11.11.11.213:2181/kafka-2 +``` +### Get consumer offsets +```shell + $ kafka-consumer-manager --cluster-type sample_type offset_get sample_consumer +``` +### Get consumer watermarks +```shell + $ kafka-consumer-manager --cluster-type sample_type get_topic_watermark sample.topic +``` +### Rebalance cluster cluster1 of type sample_cluster +```shell + $ kafka-cluster-manager --cluster-type sample_type --cluster-name cluster1 + --apply rebalance --brokers --leaders --max-partition-movements 10 + --max-leader-changes 15 +``` +### Rolling-restart a cluster +```shell + $ kafka-rolling-restart --cluster-type sample_type +``` +### Check in-sync replicas +```shell + $ kafka-check --cluster-type sample_type min_isr +``` +### Check number of unavailable replicas +```shell + $ kafka-check --cluster-type sample_type replica_unavailability +``` +## Documentation +Read the documentation at [Read the Docs](http://kafka-utils.readthedocs.io/en/latest/). +## License +Kafka-Utils is licensed under the Apache License, Version 2.0: http://www.apache.org/licenses/LICENSE-2.0 +## Contributing +Everyone is encouraged to contribute to Kafka-Utils by forking the +[Github repository](http://github.com/Yelp/kafka-utils) and making a pull request or opening an issue. + +%package -n python3-kafka-utils +Summary: Kafka management utils +Provides: python-kafka-utils +BuildRequires: python3-devel +BuildRequires: python3-setuptools +BuildRequires: python3-pip +%description -n python3-kafka-utils + clusters: + cluster-1: + broker_list: + - "cluster-elb-1:9092" + zookeeper: "11.11.11.111:2181,11.11.11.112:2181,11.11.11.113:2181/kafka-1" + cluster-2: + broker_list: + - "cluster-elb-2:9092" + zookeeper: "11.11.11.211:2181,11.11.11.212:2181,11.11.11.213:2181/kafka-2" + local_config: + cluster: cluster-1 +``` +## Install +From PyPI: +```shell + $ pip install kafka-utils +``` +## Kafka-Utils command-line interface +### List all clusters +```shell + $ kafka-utils + cluster-type sample_type: + cluster-name: cluster-1 + broker-list: cluster-elb-1:9092 + zookeeper: 11.11.11.111:2181,11.11.11.112:2181,11.11.11.113:2181/kafka-1 + cluster-name: cluster-2 + broker-list: cluster-elb-2:9092 + zookeeper: 11.11.11.211:2181,11.11.11.212:2181,11.11.11.213:2181/kafka-2 +``` +### Get consumer offsets +```shell + $ kafka-consumer-manager --cluster-type sample_type offset_get sample_consumer +``` +### Get consumer watermarks +```shell + $ kafka-consumer-manager --cluster-type sample_type get_topic_watermark sample.topic +``` +### Rebalance cluster cluster1 of type sample_cluster +```shell + $ kafka-cluster-manager --cluster-type sample_type --cluster-name cluster1 + --apply rebalance --brokers --leaders --max-partition-movements 10 + --max-leader-changes 15 +``` +### Rolling-restart a cluster +```shell + $ kafka-rolling-restart --cluster-type sample_type +``` +### Check in-sync replicas +```shell + $ kafka-check --cluster-type sample_type min_isr +``` +### Check number of unavailable replicas +```shell + $ kafka-check --cluster-type sample_type replica_unavailability +``` +## Documentation +Read the documentation at [Read the Docs](http://kafka-utils.readthedocs.io/en/latest/). +## License +Kafka-Utils is licensed under the Apache License, Version 2.0: http://www.apache.org/licenses/LICENSE-2.0 +## Contributing +Everyone is encouraged to contribute to Kafka-Utils by forking the +[Github repository](http://github.com/Yelp/kafka-utils) and making a pull request or opening an issue. + +%package help +Summary: Development documents and examples for kafka-utils +Provides: python3-kafka-utils-doc +%description help + clusters: + cluster-1: + broker_list: + - "cluster-elb-1:9092" + zookeeper: "11.11.11.111:2181,11.11.11.112:2181,11.11.11.113:2181/kafka-1" + cluster-2: + broker_list: + - "cluster-elb-2:9092" + zookeeper: "11.11.11.211:2181,11.11.11.212:2181,11.11.11.213:2181/kafka-2" + local_config: + cluster: cluster-1 +``` +## Install +From PyPI: +```shell + $ pip install kafka-utils +``` +## Kafka-Utils command-line interface +### List all clusters +```shell + $ kafka-utils + cluster-type sample_type: + cluster-name: cluster-1 + broker-list: cluster-elb-1:9092 + zookeeper: 11.11.11.111:2181,11.11.11.112:2181,11.11.11.113:2181/kafka-1 + cluster-name: cluster-2 + broker-list: cluster-elb-2:9092 + zookeeper: 11.11.11.211:2181,11.11.11.212:2181,11.11.11.213:2181/kafka-2 +``` +### Get consumer offsets +```shell + $ kafka-consumer-manager --cluster-type sample_type offset_get sample_consumer +``` +### Get consumer watermarks +```shell + $ kafka-consumer-manager --cluster-type sample_type get_topic_watermark sample.topic +``` +### Rebalance cluster cluster1 of type sample_cluster +```shell + $ kafka-cluster-manager --cluster-type sample_type --cluster-name cluster1 + --apply rebalance --brokers --leaders --max-partition-movements 10 + --max-leader-changes 15 +``` +### Rolling-restart a cluster +```shell + $ kafka-rolling-restart --cluster-type sample_type +``` +### Check in-sync replicas +```shell + $ kafka-check --cluster-type sample_type min_isr +``` +### Check number of unavailable replicas +```shell + $ kafka-check --cluster-type sample_type replica_unavailability +``` +## Documentation +Read the documentation at [Read the Docs](http://kafka-utils.readthedocs.io/en/latest/). +## License +Kafka-Utils is licensed under the Apache License, Version 2.0: http://www.apache.org/licenses/LICENSE-2.0 +## Contributing +Everyone is encouraged to contribute to Kafka-Utils by forking the +[Github repository](http://github.com/Yelp/kafka-utils) and making a pull request or opening an issue. + +%prep +%autosetup -n kafka-utils-4.1.0 + +%build +%py3_build + +%install +%py3_install +install -d -m755 %{buildroot}/%{_pkgdocdir} +if [ -d doc ]; then cp -arf doc %{buildroot}/%{_pkgdocdir}; fi +if [ -d docs ]; then cp -arf docs %{buildroot}/%{_pkgdocdir}; fi +if [ -d example ]; then cp -arf example %{buildroot}/%{_pkgdocdir}; fi +if [ -d examples ]; then cp -arf examples %{buildroot}/%{_pkgdocdir}; fi +pushd %{buildroot} +if [ -d usr/lib ]; then + find usr/lib -type f -printf "/%h/%f\n" >> filelist.lst +fi +if [ -d usr/lib64 ]; then + find usr/lib64 -type f -printf "/%h/%f\n" >> filelist.lst +fi +if [ -d usr/bin ]; then + find usr/bin -type f -printf "/%h/%f\n" >> filelist.lst +fi +if [ -d usr/sbin ]; then + find usr/sbin -type f -printf "/%h/%f\n" >> filelist.lst +fi +touch doclist.lst +if [ -d usr/share/man ]; then + find usr/share/man -type f -printf "/%h/%f.gz\n" >> doclist.lst +fi +popd +mv %{buildroot}/filelist.lst . +mv %{buildroot}/doclist.lst . + +%files -n python3-kafka-utils -f filelist.lst +%dir %{python3_sitelib}/* + +%files help -f doclist.lst +%{_docdir}/* + +%changelog +* Mon May 15 2023 Python_Bot <Python_Bot@openeuler.org> - 4.1.0-1 +- Package Spec generated @@ -0,0 +1 @@ +3d679e8521afb95bf47979f71bcea28f kafka-utils-4.1.0.tar.gz |