automatic import of python-knativekafkaopeneuler20.03

3 files changed, 423 insertions, 0 deletions

diff --git a/.gitignore b/.gitignore
index e69de29..8695545 100644
--- a/.gitignore
+++ b/.gitignore
@@ -0,0 +1 @@
+/knativekafka-0.4.0.tar.gz
diff --git a/python-knativekafka.spec b/python-knativekafka.spec
new file mode 100644
index 0000000..e323b8d
--- /dev/null
+++ b/python-knativekafka.spec
@@ -0,0 +1,421 @@
+%global _empty_manifest_terminate_build 0
+Name:		python-knativekafka
+Version:	0.4.0
+Release:	1
+Summary:	A wrapper for kafka-python used in knative
+License:	Apache Software License
+URL:		https://github.optum.com/Optum-Serverless/kafka-source/tree/master/python/knativekafka
+Source0:	https://mirrors.aliyun.com/pypi/web/packages/e0/3f/3832f13009d6f89bf9af7f39108f3c0cf7e764e595c8542354d8aa4b4e2b/knativekafka-0.4.0.tar.gz
+BuildArch:	noarch
+
+Requires:	python3-kafka-python
+
+%description
+## knativekafka
+
+knativekafka is a wrapper around kafka-python package. This package is easy to use and can be used to test the Kafka Producer in kafka-python package.
+
+Some important items to note.
+
+* This package includes the basic testing only as of now.
+
+*  Polling, parallelism etc. has not been included yet.
+
+### Installation Instructions
+
+The package is availble in PyPI which is an official repository for python package.
+pip is a package management system and is used for installing Python packages from Python Package Index (also known as PyPI). It is the most common way to install Python packages.
+Install the package in your environment from the terminal using the below pip command:
+
+`pip3 install knativekafka`
+
+
+### Pre-requisites
+
+- Python 3.x
+
+- pip3
+
+- Set the environment variable - KAFKA_BOOTSTRAP_SERVERS
+
+- Have the kafka server installed and configured with a topic
+
+
+### How to Use?
+
+* Import the Kafka Producer into your python code using the below import.
+
+`from knativekafka.knativekafkaproducer import KNativeKafkaProducer`
+
+* To import the Kafka Consumer use the below import.
+`from knativekafka.knativekafkaconsumer import KNativeKafkaConsumer`
+
+
+#### Usage
+
+* Only few features are implemented in the package as of now. 
+
+* Additional features to be included later.
+
+#### Test Producer
+
+To test the producer, perform the below steps.
+
+* Instantiate the KNativeKafkaProducer by passing the kafka topic.
+
+* Bootstrap Servers -- The init() method checks whether the os.environ() contains the KAFKA_BOOTSTRAP_SERVERS key. 
+
+* If so, it fetches the value from the environment. If not, it sets the default value as localhost:9092. 
+
+* Topic -- The topic is passed as parameter. Since, topic is a required field,if topic is an empty string, then, topic is retrieved from the environment variable. If topic is not passed and environment variable doesn't contain KAFKA_TOPIC, ValueError is thrown. To send data, use the send_binary_data() by passing the message as parameter. The send_binary_data() takes the message in binary format.
+
+* TLS Enabled -- If environment variable - KAFKA_NET_TLS_ENABLE is found and has value True, then, TLS is enabled.
+Get the tls information such as ssl_cafile, ssl_certfile and ssl_keyfile from the corresponding environment variable. The environment variables are KAFKA_NET_TLS_CA_CERT,
+KAFKA_NET_TLS_CERT and KAFKA_NET_TLS_KEY.
+
+* TLS Disabled -- If either environment variable - KAFKA_NET_TLS_ENABLE is not found or has value False, then, TLS is disabled.
+Set the value for the tls fields such as ssl_cafile, ssl_certfile and ssl_keyfile to None.
+
+```
+    topic = "python-topic"
+    kafka_producer = KNativeKafkaProducer(topic=topic)
+    value = input('value:')
+    value = bytes(value, encoding='utf8')            
+    kafka_producer.send_binary_data(value)    
+    print("Successfully sent data....") 
+
+```
+
+#### Test Consumer
+
+To test the consumer, perform the below steps.
+
+* Instantiate the KNativeKafkaConsumer by passing the topic and then, call display_message(). The display_message() prints the message values.
+
+* Bootstrap Servers -- The init() method checks whether the os.environ() contains the KAFKA_BOOTSTRAP_SERVERS key. 
+
+* If so, it fetches the value from the environment. If not, it sets the default value as localhost:9092. 
+
+* Topic -- The topic is passed as parameter. Since, topic is a required field,if topic is an empty string, then, topic is retrieved from the environment variable. If topic is not passed and environment variable doesn't contain KAFKA_TOPIC, ValueError is thrown. To send data, use the send_binary_data() by passing the message as parameter. The send_binary_data() takes the message in binary format.
+
+* TLS Enabled -- If environment variable - KAFKA_NET_TLS_ENABLE is found and has value True, then, TLS is enabled.
+Get the tls information such as ssl_cafile, ssl_certfile and ssl_keyfile from the corresponding environment variable. The environment variables are KAFKA_NET_TLS_CA_CERT,
+KAFKA_NET_TLS_CERT and KAFKA_NET_TLS_KEY.
+
+* TLS Disabled -- If either environment variable - KAFKA_NET_TLS_ENABLE is not found or has value False, then, TLS is disabled.
+Set the value for the tls fields such as ssl_cafile, ssl_certfile and ssl_keyfile to None.
+
+```
+topic = "python-topic"
+kafka_consumer =  KNativeKafkaConsumer(topics=topic)
+kafka_consumer.display_message()    
+
+
+```
+#### References
+
+- [knativekafka in test.pypi.org](https://test.pypi.org/project/knativekafka/0.4.0/)
+
+- [knativekafka in pypi.org](https://pypi.org/project/knativekafka/0.4.0/)
+
+### License
+
+```
+Apache License
+
+```
+
+
+
+
+
+%package -n python3-knativekafka
+Summary:	A wrapper for kafka-python used in knative
+Provides:	python-knativekafka
+BuildRequires:	python3-devel
+BuildRequires:	python3-setuptools
+BuildRequires:	python3-pip
+%description -n python3-knativekafka
+## knativekafka
+
+knativekafka is a wrapper around kafka-python package. This package is easy to use and can be used to test the Kafka Producer in kafka-python package.
+
+Some important items to note.
+
+* This package includes the basic testing only as of now.
+
+*  Polling, parallelism etc. has not been included yet.
+
+### Installation Instructions
+
+The package is availble in PyPI which is an official repository for python package.
+pip is a package management system and is used for installing Python packages from Python Package Index (also known as PyPI). It is the most common way to install Python packages.
+Install the package in your environment from the terminal using the below pip command:
+
+`pip3 install knativekafka`
+
+
+### Pre-requisites
+
+- Python 3.x
+
+- pip3
+
+- Set the environment variable - KAFKA_BOOTSTRAP_SERVERS
+
+- Have the kafka server installed and configured with a topic
+
+
+### How to Use?
+
+* Import the Kafka Producer into your python code using the below import.
+
+`from knativekafka.knativekafkaproducer import KNativeKafkaProducer`
+
+* To import the Kafka Consumer use the below import.
+`from knativekafka.knativekafkaconsumer import KNativeKafkaConsumer`
+
+
+#### Usage
+
+* Only few features are implemented in the package as of now. 
+
+* Additional features to be included later.
+
+#### Test Producer
+
+To test the producer, perform the below steps.
+
+* Instantiate the KNativeKafkaProducer by passing the kafka topic.
+
+* Bootstrap Servers -- The init() method checks whether the os.environ() contains the KAFKA_BOOTSTRAP_SERVERS key. 
+
+* If so, it fetches the value from the environment. If not, it sets the default value as localhost:9092. 
+
+* Topic -- The topic is passed as parameter. Since, topic is a required field,if topic is an empty string, then, topic is retrieved from the environment variable. If topic is not passed and environment variable doesn't contain KAFKA_TOPIC, ValueError is thrown. To send data, use the send_binary_data() by passing the message as parameter. The send_binary_data() takes the message in binary format.
+
+* TLS Enabled -- If environment variable - KAFKA_NET_TLS_ENABLE is found and has value True, then, TLS is enabled.
+Get the tls information such as ssl_cafile, ssl_certfile and ssl_keyfile from the corresponding environment variable. The environment variables are KAFKA_NET_TLS_CA_CERT,
+KAFKA_NET_TLS_CERT and KAFKA_NET_TLS_KEY.
+
+* TLS Disabled -- If either environment variable - KAFKA_NET_TLS_ENABLE is not found or has value False, then, TLS is disabled.
+Set the value for the tls fields such as ssl_cafile, ssl_certfile and ssl_keyfile to None.
+
+```
+    topic = "python-topic"
+    kafka_producer = KNativeKafkaProducer(topic=topic)
+    value = input('value:')
+    value = bytes(value, encoding='utf8')            
+    kafka_producer.send_binary_data(value)    
+    print("Successfully sent data....") 
+
+```
+
+#### Test Consumer
+
+To test the consumer, perform the below steps.
+
+* Instantiate the KNativeKafkaConsumer by passing the topic and then, call display_message(). The display_message() prints the message values.
+
+* Bootstrap Servers -- The init() method checks whether the os.environ() contains the KAFKA_BOOTSTRAP_SERVERS key. 
+
+* If so, it fetches the value from the environment. If not, it sets the default value as localhost:9092. 
+
+* Topic -- The topic is passed as parameter. Since, topic is a required field,if topic is an empty string, then, topic is retrieved from the environment variable. If topic is not passed and environment variable doesn't contain KAFKA_TOPIC, ValueError is thrown. To send data, use the send_binary_data() by passing the message as parameter. The send_binary_data() takes the message in binary format.
+
+* TLS Enabled -- If environment variable - KAFKA_NET_TLS_ENABLE is found and has value True, then, TLS is enabled.
+Get the tls information such as ssl_cafile, ssl_certfile and ssl_keyfile from the corresponding environment variable. The environment variables are KAFKA_NET_TLS_CA_CERT,
+KAFKA_NET_TLS_CERT and KAFKA_NET_TLS_KEY.
+
+* TLS Disabled -- If either environment variable - KAFKA_NET_TLS_ENABLE is not found or has value False, then, TLS is disabled.
+Set the value for the tls fields such as ssl_cafile, ssl_certfile and ssl_keyfile to None.
+
+```
+topic = "python-topic"
+kafka_consumer =  KNativeKafkaConsumer(topics=topic)
+kafka_consumer.display_message()    
+
+
+```
+#### References
+
+- [knativekafka in test.pypi.org](https://test.pypi.org/project/knativekafka/0.4.0/)
+
+- [knativekafka in pypi.org](https://pypi.org/project/knativekafka/0.4.0/)
+
+### License
+
+```
+Apache License
+
+```
+
+
+
+
+
+%package help
+Summary:	Development documents and examples for knativekafka
+Provides:	python3-knativekafka-doc
+%description help
+## knativekafka
+
+knativekafka is a wrapper around kafka-python package. This package is easy to use and can be used to test the Kafka Producer in kafka-python package.
+
+Some important items to note.
+
+* This package includes the basic testing only as of now.
+
+*  Polling, parallelism etc. has not been included yet.
+
+### Installation Instructions
+
+The package is availble in PyPI which is an official repository for python package.
+pip is a package management system and is used for installing Python packages from Python Package Index (also known as PyPI). It is the most common way to install Python packages.
+Install the package in your environment from the terminal using the below pip command:
+
+`pip3 install knativekafka`
+
+
+### Pre-requisites
+
+- Python 3.x
+
+- pip3
+
+- Set the environment variable - KAFKA_BOOTSTRAP_SERVERS
+
+- Have the kafka server installed and configured with a topic
+
+
+### How to Use?
+
+* Import the Kafka Producer into your python code using the below import.
+
+`from knativekafka.knativekafkaproducer import KNativeKafkaProducer`
+
+* To import the Kafka Consumer use the below import.
+`from knativekafka.knativekafkaconsumer import KNativeKafkaConsumer`
+
+
+#### Usage
+
+* Only few features are implemented in the package as of now. 
+
+* Additional features to be included later.
+
+#### Test Producer
+
+To test the producer, perform the below steps.
+
+* Instantiate the KNativeKafkaProducer by passing the kafka topic.
+
+* Bootstrap Servers -- The init() method checks whether the os.environ() contains the KAFKA_BOOTSTRAP_SERVERS key. 
+
+* If so, it fetches the value from the environment. If not, it sets the default value as localhost:9092. 
+
+* Topic -- The topic is passed as parameter. Since, topic is a required field,if topic is an empty string, then, topic is retrieved from the environment variable. If topic is not passed and environment variable doesn't contain KAFKA_TOPIC, ValueError is thrown. To send data, use the send_binary_data() by passing the message as parameter. The send_binary_data() takes the message in binary format.
+
+* TLS Enabled -- If environment variable - KAFKA_NET_TLS_ENABLE is found and has value True, then, TLS is enabled.
+Get the tls information such as ssl_cafile, ssl_certfile and ssl_keyfile from the corresponding environment variable. The environment variables are KAFKA_NET_TLS_CA_CERT,
+KAFKA_NET_TLS_CERT and KAFKA_NET_TLS_KEY.
+
+* TLS Disabled -- If either environment variable - KAFKA_NET_TLS_ENABLE is not found or has value False, then, TLS is disabled.
+Set the value for the tls fields such as ssl_cafile, ssl_certfile and ssl_keyfile to None.
+
+```
+    topic = "python-topic"
+    kafka_producer = KNativeKafkaProducer(topic=topic)
+    value = input('value:')
+    value = bytes(value, encoding='utf8')            
+    kafka_producer.send_binary_data(value)    
+    print("Successfully sent data....") 
+
+```
+
+#### Test Consumer
+
+To test the consumer, perform the below steps.
+
+* Instantiate the KNativeKafkaConsumer by passing the topic and then, call display_message(). The display_message() prints the message values.
+
+* Bootstrap Servers -- The init() method checks whether the os.environ() contains the KAFKA_BOOTSTRAP_SERVERS key. 
+
+* If so, it fetches the value from the environment. If not, it sets the default value as localhost:9092. 
+
+* Topic -- The topic is passed as parameter. Since, topic is a required field,if topic is an empty string, then, topic is retrieved from the environment variable. If topic is not passed and environment variable doesn't contain KAFKA_TOPIC, ValueError is thrown. To send data, use the send_binary_data() by passing the message as parameter. The send_binary_data() takes the message in binary format.
+
+* TLS Enabled -- If environment variable - KAFKA_NET_TLS_ENABLE is found and has value True, then, TLS is enabled.
+Get the tls information such as ssl_cafile, ssl_certfile and ssl_keyfile from the corresponding environment variable. The environment variables are KAFKA_NET_TLS_CA_CERT,
+KAFKA_NET_TLS_CERT and KAFKA_NET_TLS_KEY.
+
+* TLS Disabled -- If either environment variable - KAFKA_NET_TLS_ENABLE is not found or has value False, then, TLS is disabled.
+Set the value for the tls fields such as ssl_cafile, ssl_certfile and ssl_keyfile to None.
+
+```
+topic = "python-topic"
+kafka_consumer =  KNativeKafkaConsumer(topics=topic)
+kafka_consumer.display_message()    
+
+
+```
+#### References
+
+- [knativekafka in test.pypi.org](https://test.pypi.org/project/knativekafka/0.4.0/)
+
+- [knativekafka in pypi.org](https://pypi.org/project/knativekafka/0.4.0/)
+
+### License
+
+```
+Apache License
+
+```
+
+
+
+
+
+%prep
+%autosetup -n knativekafka-0.4.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-knativekafka -f filelist.lst
+%dir %{python3_sitelib}/*
+
+%files help -f doclist.lst
+%{_docdir}/*
+
+%changelog
+* Tue Jun 20 2023 Python_Bot <Python_Bot@openeuler.org> - 0.4.0-1
+- Package Spec generated
diff --git a/sources b/sources
new file mode 100644
index 0000000..bd0d565
--- /dev/null
+++ b/sources
@@ -0,0 +1 @@
+cf7010693391b56b796385c25366f6e3  knativekafka-0.4.0.tar.gz