wintoncode winton-kafka-streams issues

wintoncode / winton-kafka-streams

A Python implementation of Apache Kafka Streams

Apache License 2.0

313 stars 55 forks source link

issues

Newest

Newest Most commented Recently updated Oldest Least commented Least recently updated

Can this package be published to pypi with semvar versions?

#63 spacether opened 3 years ago
0
Branching in stream processing?

#62 seanrmurphy opened 4 years ago
0
Wordcount example: TypeError: an integer is required (got type tuple)

#61 dqii opened 4 years ago
2
Error decoding bytes type with logicalType decimal - Avro

#60 arhantpanda opened 5 years ago
1
Using multiple topics input

#59 AmitKalfus opened 5 years ago
0
timestamp not always integer causing crash. Now checks common cases.

#58 MaximWolpher opened 5 years ago
1
Update readme to mention pip install git+

#57 ah- closed 6 years ago
1
replay log on initialize

#56 sambott opened 6 years ago
0
State Store preparation

#55 sambott closed 6 years ago
1
Don't build for nightly Python 3.7

#54 ah- closed 6 years ago
1
modify gitignore and kafka-debug Dockerfile

#53 tfnick opened 6 years ago
2
Use commit asynchronous for python 3.7 compatibility

#52 ah- closed 6 years ago
3
Another partition problem

#51 exception13 opened 6 years ago
1
Add CLA paragraph to CONTRIBUTING guidelines

#50 llawall closed 6 years ago
1
* Fixed IndexError when list index != partition number

#49 exception13 closed 6 years ago
3
Python 3.7 support

#48 ah- closed 6 years ago
0
set consumer group.id to application_id

#47 jkramarz closed 6 years ago
1
Add read the docs configuration

#46 llawall closed 6 years ago
4
Fix wrapper_serde import on avro.py

#45 sambott closed 6 years ago
0
Add to wordcount example providing an option to use custom serialiser

#44 sambott closed 6 years ago
0
Demo an asymmetric Serde in the wordcount example

#43 sambott closed 6 years ago
1
Add support for Avro Schema Registry

#42 sambott closed 6 years ago
1
Add Schema Registry integration test

#41 sambott opened 6 years ago
0
Fix punctuate with same timestamp

#40 ah- closed 6 years ago
0
How to send using streams

#39 vlad0337187 closed 6 years ago
2
[Q] How to debug "process" method?

#38 myaspm closed 6 years ago
1
TypeError: '<' not supported between instances of 'ProcessorNode' and 'ProcessorNode'

#37 singularity-xx closed 6 years ago
2
Implement basic state change logging to kafka topic

#36 ah- closed 6 years ago
1
Handle task migrations correctly

#35 jhickson closed 6 years ago
1
Use topology builder to pass in state store to wordcount example

#34 ah- closed 6 years ago
0
Feature request: Avro support

#33 gavrie closed 6 years ago
3
Add serde

#32 sambott closed 7 years ago
1
Replace use of CommitFailedException in StreamThread

#31 jhickson closed 6 years ago
0
Make the KafkaStreamsError public

#30 jhickson closed 7 years ago
0
Extract TaskId into a class

#29 ah- closed 7 years ago
0
Small fixes for state_store

#28 szczeles closed 7 years ago
1
Add Vagrantfile

#27 sambott closed 7 years ago
1
Add serialiser/deserialiser functionality

#26 sambott closed 7 years ago
1
Fix pep8 newlines and typos

#25 ah- closed 7 years ago
0
Installation documentation improvements

#24 jhickson closed 7 years ago
0
Correctly associate source with a topic

#23 llawall closed 7 years ago
5
Implement an initial proof of concept DSL

#22 llawall opened 7 years ago
1
Add support for persistent state store

#21 llawall opened 7 years ago
0
Fix the Travis Badge

#20 ElliotJH closed 7 years ago
0
Fix Travis Badge

#19 ElliotJH closed 7 years ago
2
Add .travis.yml and badge

#18 ElliotJH closed 7 years ago
0
dockerized wordcount example

#17 sebastianneubauer closed 7 years ago
4
Improve README files for examples

#16 llawall closed 7 years ago
0
Add Read The Docs theme

#15 winton-admin closed 7 years ago
0
Take version from SCM

#14 winton-admin closed 7 years ago
0