337 Commits (43d9f68219537722b121235b1e07ca8a86a02a57)

Author SHA1 Message Date
chrislu 480fcb1d03 fix build 7 months ago
chrislu ff66155302 fix tests 7 months ago
chrislu 270e91b0be adds locking 7 months ago
chrislu b6fd1ff4ce refactor 7 months ago
vadimartynov 86d92a42b4
Added tls for http clients (#5766) 8 months ago
chrislu cb1ba0275a sort imports 9 months ago
vadimartynov 8aae82dd71
Added context for the MasterClient's methods to avoid endless loops (#5628) 9 months ago
chrislu 25b2850e7d refactor out FilerClientAccessor 9 months ago
chrislu d1f0c40402 remove per-message debug logs 9 months ago
chrislu df9d889489 fix size calculation 9 months ago
chrislu ff14dfa0ee debug 9 months ago
chrislu b485b9695c fix passing sub follower offset 9 months ago
chrislu f7b818483a fix cases when buffer wraps around 9 months ago
chrislu 9a5cc065b0 fix 9 months ago
chrislu 23a72db1df stop partitionOffsetChan if closed 9 months ago
chrislu af19256dbf skip control messages 9 months ago
chrislu ad2b878130 fix inflight message tracker 9 months ago
chrislu f8a22038c5 passing along publisher name 9 months ago
chrislu f0b9e163a0 avoid nil stopChan 9 months ago
chrislu a5874954dc less logs 9 months ago
chrislu edc87c16f9 balance subscribers 9 months ago
chrislu 6366898af2 add market 9 months ago
chrislu 96b326a304 use type ConsumerGroupInstanceId 9 months ago
chrislu 37d1ee562d refactor 9 months ago
chrislu cdeaaf95b4 go fmt 9 months ago
chrislu d40b350f54 coordinator receives unassignment ack 9 months ago
chrislu 554ae09f82 rename 9 months ago
chrislu 6ef2d010aa rename file 9 months ago
chrislu 67e6051585 rename Coordinator to SubCoordinator 9 months ago
chrislu b5099263a4 rename file 9 months ago
chrislu d5abffa42c rename Balancer to PubBalancer 9 months ago
chrislu fa98ecf71e client side stop partition subscribing if unassigned 9 months ago
chrislu 6634b42981 fix compilation 9 months ago
chrislu 2190d59bc3 refactor 9 months ago
chrislu 3148dec1f6 avoid concurrent processing for the same key 9 months ago
chrislu a7d30d0705 refactor 9 months ago
chrislu 33aecb7bb4 remove ProcessorConfiguration 9 months ago
chrislu 65dd5ac6fb fix 9 months ago
chrislu f13475ac2e sending keyed offset 9 months ago
chrislu d45b1d058d minor 9 months ago
chrislu 3622196881 go fmt 9 months ago
chrislu d218fe54fa go fmt 9 months ago
chrislu 7a4ace5dfb adjust logs 9 months ago
chrislu d8ab22012a track offset 9 months ago
chrislu 2b07a40da5 add InflightMessageTracker 9 months ago
chrislu a2885512e1 fix 10 months ago
chrislu 8d02712c63 ConcurrentPartitionLimit 10 months ago
chrislu 8ce2cced47 less logs 10 months ago
chrislu c6db3f31a1 start consuming ASAP 10 months ago
chrislu c21b32dd20 logs 10 months ago