Skip to content

Latest commit

 

History

History
53 lines (29 loc) · 1.94 KB

README.md

File metadata and controls

53 lines (29 loc) · 1.94 KB
Raw

Unit tests

From top-level directory run:

$ tox

NOTE: This requires tox ( please install with pip install tox ) and several supported versions of Python.

Integration tests

WARNING: These tests require an active Kafka cluster and will create new topics.

To run all of the integration test modes uncomment the following line from tox.ini and add the addresses to your Kafka and Confluent Schema Registry instances.

#python examples/integration_test.py <bootstrap-servers> confluent-kafka-testing [<schema-registry-url>]

You can also run the integration tests outside of tox by running this command from the source root directory

examples/integration_test.py <kafka-broker> [<test-topic>] [<schema-registry>]

To run individual integration test modes use the following syntax

 examples/integration_test.py --<test mode>  <kafka-broker> [<test-topic>] [<schema-registry>]

For example:

examples/integration_test.py --producer <kafka-broker> [<test-topic>]

To get a list of modes you can run the integration test manually with the --help flag

examples/integration_tests.py --help

The throttle_cb integration test requires an additional step and as such is not included in the default test modes. In order to execute the throttle_cb test you must first set a throttle for the client 'throttled_client' with the command below:

kafka-configs  --zookeeper <zookeeper host>:<zookeeper port> \
    --alter --add-config 'request_percentage=01' \
    --entity-name throttled_client --entity-type clients

Once the throttle has been set you can proceed with the following command:

examples/integration_test.py --throttle <kafka-broker> [<test-topic>]

To remove the throttle you can execute the following

kafka-configs  --zookeeper <zookeeper host>:<zookeeper port> \
    --alter --delete-config 'request_percentage' \
    --entity-name throttled_client --entity-type clients