real-digital / esque / 875 / 4
90%
master: 90%

DEFAULT BRANCH: master
Ran
Files 33
Run time 3s
Badge
Embed ▾
README BADGES
x

If you need to use a raster PNG badge, change the '.svg' to '.png' in the link

Markdown

Textile

RDoc

HTML

Rst
coverage: 87.762% (+1.9%) from 85.824%
TEST_CMD="pytest tests/ --integration --cov=esque --local" BROKER_URL="localhost:9092" ZOOKEEPER_URL="localhost:2181" SCHEMA_REGISTRY_URL="localhost:8081" CONFIG_PATH="confluent-community/etc/kafka/server.properties" KAFKA_AUTO_CREATE_TOPICS_ENABLE="False"

push

travis-ci

web-flow 
84 split transfer into consume produce (#91)

* [WIP] - preserving order when consuming messages from multiple partitions

* WIP: Proof of concept for the consumer logic.

* WIP: Completed the consume function.

* WIP: Added a new option to the consume function that checks if the message order should be preserved.

* WIP: Consumer refactoring and basic producer functionality.

* Produce command added, minor refactoring for message deserialization.

* WIP: Changes to the input and output procedures.

* Added integration tests for consume and produce operations.

* Merge commit, import fixes.

* Added a pause between consecutive messages in test, to insure the proper order while writing.

* Formatting changes.

* Added more tests.

* Formatting changes.

* Update esque/messages/message.py

Co-Authored-By: Jannik Hoffjann <jannik.hoffjann@real-digital.de>

* Comment resolutions.

* Fixed an issue with printing Avro messages to stdout. Refactored the consumers.

* Removed newline from stdin generated messages.

* Producing doesn't stop if there is one incorrect message on stdin.

* Enabled grouping imports with the same source.

* Update esque/clients/consumer.py

Co-Authored-By: Swen Wenzel <5111028+swenzel@users.noreply.github.com>

* Update esque/clients/consumer.py

Co-Authored-By: Swen Wenzel <5111028+swenzel@users.noreply.github.com>

* Update esque/clients/consumer.py

Co-Authored-By: Swen Wenzel <5111028+swenzel@users.noreply.github.com>

* Update esque/clients/consumer.py

Co-Authored-By: Swen Wenzel <5111028+swenzel@users.noreply.github.com>

* Update esque/clients/producer.py

Co-Authored-By: Swen Wenzel <5111028+swenzel@users.noreply.github.com>

* Update esque/clients/consumer.py

Co-Authored-By: Swen Wenzel <5111028+swenzel@users.noreply.github.com>

* Update esque/clients/producer.py

Co-Authored-By: Swen Wenzel <5111028+swenzel@users.noreply.github.com>

* Update esque/cli... (continued)

1929 of 2198 relevant lines covered (87.76%)

0.88 hits per line

Source Files on job 875.4 (TEST_CMD="pytest tests/ --integration --cov=esque --local" BROKER_URL="localhost:9092" ZOOKEEPER_URL="localhost:2181" SCHEMA_REGISTRY_URL="localhost:8081" CONFIG_PATH="confluent-community/etc/kafka/server.properties" KAFKA_AUTO_CREATE_TOPICS_ENABLE="False" )