winton-kafka-streams

winton-kafka-streams copied to clipboard

Error decoding bytes type with logicalType decimal - Avro

1

I have the following Avro schema for a field that is a `decimal` logicalType. ``` { "name": "amount", "type": [ "null", { "type": "bytes", "scale": 2, "precision": 10, "connect.version": 1,...

arhantpanda

Can this package be published to pypi with semvar versions?

spacether

Kafka provides support for branching in the topology: https://jaceklaskowski.gitbooks.io/mastering-kafka-streams/content/kafka-streams-internals-KStreamBranch.html I think this is not explicitly supported in this library - is this correct? Any indicator how such functionality could be...

seanrmurphy

Wordcount example: TypeError: an integer is required (got type tuple)

2

I'm getting an error when I run the wordcount example. I cloned the git repo and did not make any changes. The issue seems to be that timestamp is represented...

dqii

modify gitignore and kafka-debug Dockerfile

2

because of kafka 0.10.1.0' s tgz download link is invalid, fix it.

tfnick

timestamp not always integer causing crash. Now checks common cases.

1

Noticed that the timestamp is not always passed correctly to producer.produce(). This is only a quick fix, but perhaps the root of the problem should be investigated.

MaximWolpher

Hi, Is there code support for using multiple consumers for different topics and topic groups? seems like I can add several sources, but I haven't found a location to configure...

AmitKalfus

Replays State topic to rebuild local state on start.

sambott

Considering renaming to kafka-streams?

3

as this is the import name this name would stick for a long time, if not changed now... Suggestions: * kafka-streams * py-kafka-streams

sebastianneubauer

Another partition problem

1

if use multiple process/threads with partitioning topic current realization StoreChangeLogger try write with specified partition without checking and repartition this topic. Any ideas?

exception13