Kafka.jl

Kafka.jl copied to clipboard

Update for Julia 1.0

1

rakeroots

Update README.md to reflect examples/all.jl (Update for Julia 1.0)

rakeroots

Dealing with partitions (and consumer groups)

14

Hi, we're extending our work with Kafka and a microservice in Julia. Now we have for a topic "mytopic" three different partitions. Very basically, I'm initializing my client using `kc...

akubisch

Server behavior described in [Client-side assignment](https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Client-side+Assignment+Proposal). Client protocol described in [Group membership API](https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-GroupMembershipAPI). Steps to implement: - [x] Read documentation for consumer synchronization - [x] Figure out how to handle...

dfdx

- [ ] commit offsets - [ ] fetch offsets

dfdx

Update to Kafka 1.0.0 and Julia 0.6

8

Hi, I got the library working in Julia 0.6 but it doesn't work with Kafka 1.0.0. Is there any chance you could take a look? Julia 0.6 updates - https://github.com/GearsAD/Kafka.jl...

GearsAD