real-digital / esque / 875
90%

DEFAULT BRANCH: master
Ran
Jobs 4
Files 0
Run time –
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
875

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)
Jobs
ID Job ID Ran Files Coverage
1 875.1 (TEST_CMD="poetry run -- black --check --verbose .") 0
Travis Job 875.1
2 875.2 (TEST_CMD="poetry run -- isort --recursive .") 0
Travis Job 875.2
3 875.3 (TEST_CMD="poetry run -- flake8 esque/") 0
Travis Job 875.3
4 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" ) 0
87.76
 Travis Job 875.4
Source Files on build 875
Detailed source file information is not available for this build.