veritone/go-messaging-lib issues and pull requests

#68 - VTN-29799, Add a new method ProduceManualPartition to produce msg to a partition

Pull Request - State: closed - Opened by cantv6605-seta about 5 years ago - 2 comments

#67 - VTN-29170 Add TLS config to nsq

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

#66 - VTN-26109, add StrategyHashMurmur2

Pull Request - State: closed - Opened by ctsiokos-veritone over 5 years ago

#65 - VTN-23454 . - Add log for kafka error message

Pull Request - State: closed - Opened by dduyVeritone over 5 years ago

#64 - vtn-19174 let event chan close on its own

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

#63 - copy topic to underlying kafka message

Pull Request - State: closed - Opened by mezzi over 5 years ago

#62 - Producer group wrapper for multiple producers

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

#61 - Skip bad broker when list topics

Pull Request - State: closed - Opened by dduyVeritone almost 6 years ago - 4 comments

#60 - VTN-2758 - Add test to verify consumer connect to all brokers

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

#59 - Emit number of marked messages metrics

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

#58 - Consolidate sarama config

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

#57 - VTN-11482 - Extend metric request timeout to 30s + add metrics

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

#56 - Fix message buffering and "send on closed chan" panic

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

#55 - Mark offset only after sending to channel

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

#54 - transfer partition and offset of produced message to original message

Pull Request - State: closed - Opened by mezzi almost 6 years ago - 3 comments

#53 - VTN-11578, remove intermediate channel in consumer

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

#52 - VTN-11482 - Add timeout for manager request

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

#51 - VTN-11482 - Retry more on admin & expose sarama log option

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

#50 - VTN-11012, add option for initial offset

Pull Request - State: closed - Opened by ctsiokos-veritone almost 6 years ago - 2 comments

#49 - Retry metadata on for single consumer

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

#48 - More metadata retry

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

#47 - More metadata retry

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

#46 - VTN-10864 More retries on consumer & producer

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

#45 - Update sample

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

#44 - Set automark to true by default

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

#43 - VTN-9050 Expose kafka specific interface

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

#42 - VTN-7492 Manual consumer offset commit support

Pull Request - State: closed - Opened by dduyVeritone about 6 years ago - 2 comments

#41 - fix interface for producer from kafka implementation

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

#40 - update deps and uuid

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

#39 - Exp/trace

Pull Request - State: closed - Opened by fuzzdota about 6 years ago - 1 comment

#38 - cover edge case when log retention is expired

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#37 - Feat/vtn 8484

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#36 - Add ListTopicsLite version

Pull Request - State: closed - Opened by fuzzdota over 6 years ago - 4 comments

#35 - Feat/nsqlookup consul

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#34 - add constructors that take in old config type

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#33 - display only valid consumer groups for any given topic

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#32 - include interface mocks for unit testing

Pull Request - State: closed - Opened by mezzi over 6 years ago

#31 - VTN-7566 Recover from Sarama panics

Pull Request - State: closed - Opened by tnguyen-veri over 6 years ago - 1 comment

#30 - return error when creating producer for nsq

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#29 - Set consumer group clients to start at oldest offset

Pull Request - State: closed - Opened by veri-jebenezer over 6 years ago

#28 - replace kafka-go with sarama for producer

Pull Request - State: closed - Opened by fuzzdota over 6 years ago - 3 comments

#27 - Fix/close brokers

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#26 - reduce goroutine usage

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#25 - disable go-metrics

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#24 - Feat/broker cleanup

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#23 - AddPartitions feature + test

Pull Request - State: closed - Opened by fuzzdota over 6 years ago - 2 comments

#22 - export alias for kafka-go Message type

Pull Request - State: closed - Opened by mezzi over 6 years ago

#21 - Fix/dependencies+test, add DeleteTopics

Pull Request - State: closed - Opened by fuzzdota over 6 years ago - 2 comments

#20 - Update README and docs for NewMessage

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#19 - closing consumers gracefully w/ tests

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#18 - fix high CPU usage for idling consumer; stay consistent with API version

Pull Request - State: closed - Opened by fuzzdota over 6 years ago - 1 comment

#17 - list topics without consumer groups

Pull Request - State: closed - Opened by fuzzdota over 6 years ago - 1 comment

#16 - Feat/custome hostname

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#15 - close connection on create topics and list topics

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#14 - optimize list topics

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#13 - filter out __consumer_offsets to improve perf

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#12 - using sarama client requires us to commit offset manually

Pull Request - State: closed - Opened by fuzzdota over 6 years ago - 1 comment

#11 - multiple hosts for manager

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#10 - handle connection failure

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#9 - fail early when group ID is empty

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#8 - fixing starved consumer with sarama

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#7 - Initial NSQ support

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#6 - Core Event - BREAKING CHANGES

Pull Request - State: closed - Opened by fuzzdota over 6 years ago - 4 comments

#5 - update example and bake in prometheus metrics

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#4 - set low latency for basic usage remove manual offset commit

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#3 - Topics, not Topic

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#2 - listing topics

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

#1 - add retry for auto-creation of topic & partition

Pull Request - State: closed - Opened by fuzzdota over 6 years ago

GitHub / veritone/go-messaging-lib issues and pull requests