OSS Sync | Mon Sep 11 11:20:30 UTC 2023#569

Open

berman7 wants to merge 55 commits intomasterfrom

oss-sync-1694430751980

Commits on Sep 11, 2023

Ds scalafmt (#32485)

Leon Burdinov
authored and
wix-oss
committed
Remove unused test deps (#33323)

authored and
wix-oss
committed
Blocking retries attempts tracking fix (#32757)

atamurius
authored and
wix-oss
committed
Revert "Blocking retries attempts tracking fix" (#33818)

natansil
authored and
wix-oss
committed
[greyhound] remove internal topic creation - wix adapter (#33820)

berman7
authored and
wix-oss
committed
[greyhound] parallel consumer OffsetsAndGaps (#33605)

ben-wattelman
authored and
wix-oss
committed
Blocking retries attempts tracking fix + fix transitive header bug (#33827)

natansil
authored and
wix-oss
committed
[greyhound] expose internal kafka producer metrics (#34160)

berman7
authored and
wix-oss
committed
[greyhound] Cooperative Rebalance fix (#34153)

Leon Burdinov
authored and
wix-oss
committed
code cleanup (#34171)

Leon Burdinov
authored and
wix-oss
committed
[greyhound] parallel consumer implementation (#34061)

ben-wattelman
authored and
wix-oss
committed
[gh-consumers-proxy] s3 bridge (#34839)

berman7
authored and
wix-oss
committed
[greyhound] parallel consumer - add visibility (#34908)

ben-wattelman
authored and
wix-oss
committed
[greyhound] parallel consumer visibility (#34926)

ben-wattelman
authored and
wix-oss
committed
[greyhound] parallel consumer - add offsets and gaps init (#35027)

ben-wattelman
authored and
wix-oss
committed
[greyhound] parallel consumer - add grouping for no-key records (#35071)

ben-wattelman
authored and
wix-oss
committed
make GreyhoundNG RetryConfig serializable (so can be sent over gRpc and persisted) (#35207)

authored and
wix-oss
committed
multi-tenant consumer proxy redesign - initial commit (#35244)

berman7
authored and
wix-oss
committed
[greyhound] parallel consumer - add gaps limit (#35313)

ben-wattelman
authored and
wix-oss
committed
Fixes in preparation for ZIO 2.0.15 (#35320)

Leon Burdinov
authored and
wix-oss
committed
[greyhound-consumer-proxy] start from latest offset when group doesn't exist (temporary until full config is done) (#35428)

berman7
authored and
wix-oss
committed
[greyhound] parallel consumer - compression and encoding for gaps limit (#35423)

ben-wattelman
authored and
wix-oss
committed
greyhound proxy non blocking retries (#35456)

natansil
authored and
wix-oss
committed
new kafka monitor server for proxy (currently) (#35598)

berman7
authored and
wix-oss
committed
[greyhound] fix OffsetsInitializer metadata bug (#35684)

ben-wattelman
authored and
wix-oss
committed
ConsumerIT: add a test: allow to override offsetReset with autoResetOffset from extra properties (#35845)

natansil
authored and
wix-oss
committed
gh RecordConsumer - add visibility to extra properties setup with auto.offset.reset (#35848)

natansil
authored and
wix-oss
committed
gh RecordConsumer - allow to override offsetReset with autoResetOffset from extra properties taking into account a non-zero rewindUncommittedOffsetsBy (#35863)

natansil
authored and
wix-oss
committed
[greyhound] gaps limit calculation script (#35898)

ben-wattelman
authored and
wix-oss
committed
[greyhound] parallel consumer - update gaps limit (#35902)

ben-wattelman
authored and
wix-oss
committed
[gh-consumer-proxy] fix: if position is lower than beginning offset - move forward to first offset (#35924)

berman7
authored and
wix-oss
committed
fix build for greyhound publish to maven (#35951)

natansil
authored and
wix-oss
committed
[greyhound] parallel consumer - improve logging (#36009)

ben-wattelman
authored and
wix-oss
committed
[greyhound] parallel consumer - add logs (#36082)

ben-wattelman
authored and
wix-oss
committed
[greyhound] parallel consumer - fix update bug (#36161)

ben-wattelman
authored and
wix-oss
committed
[greyhound] change onPartitionsAssigned result to DelayedRebalanceEffect (#36206)

ben-wattelman
authored and
wix-oss
committed
fix batch consumer test timeout interruption (#36246)

Leon Burdinov
authored and
wix-oss
committed
[greyhound] parallel consumer - fix skip logic (#36281)

ben-wattelman
authored and
wix-oss
committed
[greyhound] parallel consumer - improve visibility (#36346)

ben-wattelman
authored and
wix-oss
committed
[greyhound] parallel consumer - init gaps on every rebalance (#36375)

ben-wattelman
authored and
wix-oss
committed
[greyhound] parallel cosnumer - add init log (#36421)

ben-wattelman
authored and
wix-oss
committed
[greyhound] parallel consumer - fix shutdown (#36489)

ben-wattelman
authored and
wix-oss
committed
[greyhound] add shutdown visibility (#36571)

ben-wattelman
authored and
wix-oss
committed
[greyhound] parallel consumer - interrupt fiber on shutdown timeout (#36642)

ben-wattelman
authored and
wix-oss
committed
[greyhound] parallel consumer - add disconnect on shutdown (#36660)

ben-wattelman
authored and
wix-oss
committed
[greyhound] parallel consumer - add OffsetsAndGaps visibility (#36685)

ben-wattelman
authored and
wix-oss
committed
enrich commit metadata with pod and timestamp (#36679)

Leon Burdinov
authored and
wix-oss
committed
Metadata to commit log (#36749)

Leon Burdinov
authored and
wix-oss
committed
GH commit metadata ts is in UTC (#36774)

Leon Burdinov
authored and
wix-oss
committed
moved enrich metadata out of GH core. add it to commit on rebalance (#36783)

Leon Burdinov
authored and
wix-oss
committed
[greyhound] parallel consumer - remove noisy logs (#36777)

ben-wattelman
authored and
wix-oss
committed
[consumer-proxy] fix retry bug (#36902)

berman7
authored and
wix-oss
committed
[greyhound] consumer: produceWithoutShutdown under flag (#36895)

assafj-wix
authored and
wix-oss
committed
gh-consumer-proxy - init offsets 6 minutes back for non-committed partitions (#37048)

natansil
authored and
wix-oss
committed
[greyhound] use no-interruption-retry toggle in blocking retries as well (#37095)

berman7
authored and
wix-oss
committed