Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / qntfy/frafka issues and pull requests

#15 - Add kafka compression and arbitrary config, bump to go 1.14

Pull Request - State: closed - Opened by JoshuaC215 over 4 years ago

#14 - upgrade confluent kafka dependency to 1.4.2 (#12)

Pull Request - State: closed - Opened by maxthomas over 4 years ago - 1 comment

#13 - expose simpler way of creating sink without *viper.Config

Pull Request - State: closed - Opened by maxthomas about 5 years ago

#12 - Update librdkafka dependency to v1.0.0

Issue - State: open - Opened by thomas-tharp over 5 years ago

#11 - Add `KAFKA_MAX_BUFFER_KB` to configure librdkafka buffer size

Pull Request - State: closed - Opened by JoshuaC215 over 5 years ago - 1 comment

#10 - Add support for Sink.Close() being called multiple times

Pull Request - State: closed - Opened by JoshuaC215 almost 6 years ago - 1 comment

#9 - Add support for Sink.Close() being called multiple times

Pull Request - State: closed - Opened by JoshuaC215 almost 6 years ago

#8 - Print statements

Pull Request - State: closed - Opened by JoshuaC215 almost 6 years ago

#7 - Add Source.Ping(), include in InitSource() and tests

Pull Request - State: closed - Opened by JoshuaC215 almost 6 years ago - 1 comment

#6 - Update confluent-kafka-go to v0.11.6

Pull Request - State: closed - Opened by JoshuaC215 almost 6 years ago

#5 - Skip sending EOF or OffsetsCommitted to Events() unless there's an error

Pull Request - State: closed - Opened by JoshuaC215 almost 6 years ago

#4 - Update test instructions in README

Pull Request - State: closed - Opened by JoshuaC215 about 6 years ago

#3 - add badges

Pull Request - State: closed - Opened by JoshuaC215 about 6 years ago

#2 - Initial Migration / update for travis

Pull Request - State: closed - Opened by JoshuaC215 about 6 years ago

#1 - Deep offset commit resilience in Source

Issue - State: open - Opened by JoshuaC215 about 6 years ago