%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.aliyun.com/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 * Thu Jun 08 2023 Python_Bot - 4.1.0-1 - Package Spec generated