Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

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

Open
wants to merge 55 commits into
base: master
Choose a base branch
from
Open

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

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
55 commits
Select commit Hold shift + click to select a range
1c7b3ce
Ds scalafmt (#32485)
leonbur Feb 6, 2023
3d3a2c0
Remove unused test deps (#33323)
Mar 10, 2023
e276ca6
Blocking retries attempts tracking fix (#32757)
atamurius Mar 14, 2023
eb184b2
Revert "Blocking retries attempts tracking fix" (#33818)
natansil Apr 3, 2023
52de8e7
[greyhound] remove internal topic creation - wix adapter (#33820)
berman7 Apr 3, 2023
271302e
[greyhound] parallel consumer OffsetsAndGaps (#33605)
ben-wattelman Apr 4, 2023
b90bbfa
Blocking retries attempts tracking fix + fix transitive header bug (#…
natansil Apr 4, 2023
305c732
[greyhound] expose internal kafka producer metrics (#34160)
berman7 Apr 22, 2023
a06705c
[greyhound] Cooperative Rebalance fix (#34153)
leonbur Apr 23, 2023
d81a795
code cleanup (#34171)
leonbur Apr 23, 2023
0dc2bdb
[greyhound] parallel consumer implementation (#34061)
ben-wattelman May 24, 2023
0abd3fc
[gh-consumers-proxy] s3 bridge (#34839)
berman7 May 29, 2023
86d8e73
[greyhound] parallel consumer - add visibility (#34908)
ben-wattelman May 30, 2023
fb833c6
[greyhound] parallel consumer visibility (#34926)
ben-wattelman Jun 1, 2023
d73a3bd
[greyhound] parallel consumer - add offsets and gaps init (#35027)
ben-wattelman Jun 6, 2023
1d2929d
[greyhound] parallel consumer - add grouping for no-key records (#35071)
ben-wattelman Jun 11, 2023
f4cad57
make GreyhoundNG RetryConfig serializable (so can be sent over gRpc a…
natansil Jun 13, 2023
f740257
multi-tenant consumer proxy redesign - initial commit (#35244)
berman7 Jun 17, 2023
dcffb99
[greyhound] parallel consumer - add gaps limit (#35313)
ben-wattelman Jun 20, 2023
eaf82f8
Fixes in preparation for ZIO 2.0.15 (#35320)
leonbur Jun 21, 2023
7bf6ccf
[greyhound-consumer-proxy] start from latest offset when group doesn'…
berman7 Jun 22, 2023
ab23221
[greyhound] parallel consumer - compression and encoding for gaps lim…
ben-wattelman Jun 25, 2023
18fab35
greyhound proxy non blocking retries (#35456)
natansil Jun 29, 2023
b02c6fe
new kafka monitor server for proxy (currently) (#35598)
berman7 Jul 2, 2023
1b0b972
[greyhound] fix OffsetsInitializer metadata bug (#35684)
ben-wattelman Jul 6, 2023
90ad440
ConsumerIT: add a test: allow to override offsetReset with autoResetO…
natansil Jul 13, 2023
650fb79
gh RecordConsumer - add visibility to extra properties setup with aut…
natansil Jul 13, 2023
dc37dfc
gh RecordConsumer - allow to override offsetReset with autoResetOffse…
natansil Jul 16, 2023
219f82e
[greyhound] gaps limit calculation script (#35898)
ben-wattelman Jul 16, 2023
a56e65c
[greyhound] parallel consumer - update gaps limit (#35902)
ben-wattelman Jul 16, 2023
dfdbe0e
[gh-consumer-proxy] fix: if position is lower than beginning offset -…
berman7 Jul 16, 2023
f1b1624
fix build for greyhound publish to maven (#35951)
natansil Jul 18, 2023
c688fe2
[greyhound] parallel consumer - improve logging (#36009)
ben-wattelman Jul 20, 2023
510f31a
[greyhound] parallel consumer - add logs (#36082)
ben-wattelman Jul 24, 2023
e1bd65f
[greyhound] parallel consumer - fix update bug (#36161)
ben-wattelman Jul 26, 2023
a15f4a0
[greyhound] change onPartitionsAssigned result to DelayedRebalanceEff…
ben-wattelman Jul 27, 2023
a665919
fix batch consumer test timeout interruption (#36246)
leonbur Jul 30, 2023
c3f1545
[greyhound] parallel consumer - fix skip logic (#36281)
ben-wattelman Jul 31, 2023
d050887
[greyhound] parallel consumer - improve visibility (#36346)
ben-wattelman Aug 3, 2023
eb6b1b8
[greyhound] parallel consumer - init gaps on every rebalance (#36375)
ben-wattelman Aug 9, 2023
9287458
[greyhound] parallel cosnumer - add init log (#36421)
ben-wattelman Aug 9, 2023
7c836d9
[greyhound] parallel consumer - fix shutdown (#36489)
ben-wattelman Aug 15, 2023
248de42
[greyhound] add shutdown visibility (#36571)
ben-wattelman Aug 16, 2023
3983f05
[greyhound] parallel consumer - interrupt fiber on shutdown timeout (…
ben-wattelman Aug 20, 2023
dc554df
[greyhound] parallel consumer - add disconnect on shutdown (#36660)
ben-wattelman Aug 21, 2023
c113286
[greyhound] parallel consumer - add OffsetsAndGaps visibility (#36685)
ben-wattelman Aug 22, 2023
8863bc0
enrich commit metadata with pod and timestamp (#36679)
leonbur Aug 23, 2023
bc847eb
Metadata to commit log (#36749)
leonbur Aug 27, 2023
f7ee844
GH commit metadata ts is in UTC (#36774)
leonbur Aug 28, 2023
b7922ce
moved enrich metadata out of GH core. add it to commit on rebalance (…
leonbur Aug 28, 2023
54aa335
[greyhound] parallel consumer - remove noisy logs (#36777)
ben-wattelman Aug 28, 2023
08695e9
[consumer-proxy] fix retry bug (#36902)
berman7 Sep 3, 2023
9a3603e
[greyhound] consumer: produceWithoutShutdown under flag (#36895)
assafj-wix Sep 4, 2023
4b36171
gh-consumer-proxy - init offsets 6 minutes back for non-committed par…
natansil Sep 8, 2023
d83b43b
[greyhound] use no-interruption-retry toggle in blocking retries as w…
berman7 Sep 11, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions core/BUILD.bazel
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@ scala_library(
srcs = [
"//core/src/main/scala/com/wixpress/dst/greyhound/core:sources",
"//core/src/main/scala/com/wixpress/dst/greyhound/core/admin:sources",
"//core/src/main/scala/com/wixpress/dst/greyhound/core/compression:sources",
"//core/src/main/scala/com/wixpress/dst/greyhound/core/consumer:sources",
"//core/src/main/scala/com/wixpress/dst/greyhound/core/consumer/batched:sources",
"//core/src/main/scala/com/wixpress/dst/greyhound/core/consumer/domain:sources",
Expand All @@ -26,6 +27,7 @@ scala_library(
"@dev_zio_zio_managed_2_12",
"@dev_zio_zio_stacktracer_2_12",
"@dev_zio_zio_streams_2_12",
"@org_apache_commons_commons_compress",
"@org_apache_kafka_kafka_clients",
"@org_slf4j_slf4j_api",
],
Expand Down
6 changes: 3 additions & 3 deletions core/src/it/scala/com/wixpress/dst/greyhound/core/AdminClientIT.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ import com.wixpress.dst.greyhound.core.producer.ProducerRecord
import com.wixpress.dst.greyhound.core.testkit.{BaseTestWithSharedEnv, TestMetrics}
import com.wixpress.dst.greyhound.core.zioutils.CountDownLatch
import com.wixpress.dst.greyhound.testenv.ITEnv
import com.wixpress.dst.greyhound.testenv.ITEnv.{Env, TestResources, testResources}
import com.wixpress.dst.greyhound.testenv.ITEnv.{testResources, Env, TestResources}
import org.apache.kafka.common.config.TopicConfig.{DELETE_RETENTION_MS_CONFIG, MAX_MESSAGE_BYTES_CONFIG, RETENTION_MS_CONFIG}
import org.apache.kafka.common.errors.InvalidTopicException
import org.specs2.specification.core.Fragments
Expand Down Expand Up @@ -83,7 +83,7 @@ class AdminClientIT extends BaseTestWithSharedEnv[Env, TestResources] {
}
}

//todo uncomment this after https://github.com/wix-private/core-server-build-tools/pull/13043 is merged
// todo uncomment this after https://github.com/wix-private/core-server-build-tools/pull/13043 is merged
// "reflect errors" in {
// val topic1 = aTopicConfig()
// val topic2 = aTopicConfig("x" * 250)
Expand All @@ -104,7 +104,7 @@ class AdminClientIT extends BaseTestWithSharedEnv[Env, TestResources] {
// created === Map(badTopic.name -> None)
// }
// }
//todo uncomment this after https://github.com/wix-private/core-server-build-tools/pull/13043 is merged
// todo uncomment this after https://github.com/wix-private/core-server-build-tools/pull/13043 is merged
// =================================================================================================================================
"ignore TopicExistsException by default" in {
val topic = aTopicConfig()
Expand Down
5 changes: 0 additions & 5 deletions core/src/it/scala/com/wixpress/dst/greyhound/core/BUILD.bazel
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,13 +24,8 @@ specs2_ite2e_test(
"//core/src/main/scala/com/wixpress/dst/greyhound/core/producer",
"//core/src/main/scala/com/wixpress/dst/greyhound/core/zioutils",
"//core/src/test/resources",
#"//core/src/test/scala/com/wixpress/dst/greyhound/core/consumer",
#"//core/src/test/scala/com/wixpress/dst/greyhound/core/testkit",
"@ch_qos_logback_logback_classic",
# "@dev_zio_izumi_reflect_2_12",
"@dev_zio_zio_2_12",
"@dev_zio_zio_test_2_12",
"@org_apache_kafka_kafka_2_12",
"@org_apache_kafka_kafka_clients",
"//core/src/test/scala/com/wixpress/dst/greyhound/core/testkit",
],
Expand Down
957 changes: 564 additions & 393 deletions core/src/it/scala/com/wixpress/dst/greyhound/core/ConsumerIT.scala
View file
Open in desktop

Large diffs are not rendered by default.

1 change: 1 addition & 0 deletions core/src/it/scala/com/wixpress/dst/greyhound/core/batched/BatchedConsumerIT.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -212,6 +212,7 @@ class BatchedConsumerIT extends BaseTestWithSharedEnv[Env, TestResources] {
) *>
barrier
.offer(())
.interruptible
// we can't block here, otherwise rebalance won't happen - so we just fail
.timeoutFail(new RuntimeException("queue full"))(1.second)
.tapError(_ => ZIO.succeed(println(s"[$id] timed out waiting on barrier")))
Expand Down
3 changes: 0 additions & 3 deletions core/src/it/scala/com/wixpress/dst/greyhound/core/offset/BUILD.bazel
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,6 @@ specs2_ite2e_test(
"@dev_zio_izumi_reflect_2_12",
"@dev_zio_zio_managed_2_12",
"//core/src/it/resources",
"//core/src/it/scala/com/wixpress/dst/greyhound/core",
"//core/src/it/scala/com/wixpress/dst/greyhound/testenv",
"//core/src/it/scala/com/wixpress/dst/greyhound/testkit",
"//core/src/main/scala/com/wixpress/dst/greyhound/core",
Expand All @@ -23,9 +22,7 @@ specs2_ite2e_test(
"//core/src/main/scala/com/wixpress/dst/greyhound/core/metrics",
"//core/src/main/scala/com/wixpress/dst/greyhound/core/producer",
"//core/src/main/scala/com/wixpress/dst/greyhound/core/zioutils",
"//core/src/test/scala/com/wixpress/dst/greyhound/core/consumer",
"//core/src/test/scala/com/wixpress/dst/greyhound/core/testkit",
"@ch_qos_logback_logback_classic",
# "@dev_zio_izumi_reflect_2_12",
"@dev_zio_zio_2_12",
"@org_apache_kafka_kafka_clients",
Expand Down
27 changes: 27 additions & 0 deletions core/src/it/scala/com/wixpress/dst/greyhound/core/parallel/BUILD.bazel
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,27 @@
package(default_visibility = ["//visibility:public"])

sources()

specs2_ite2e_test(
name = "parallel",
srcs = [
":sources",
],
deps = [
"//core/src/it/resources",
"//core/src/it/scala/com/wixpress/dst/greyhound/testenv",
"//core/src/it/scala/com/wixpress/dst/greyhound/testkit",
"//core/src/main/scala/com/wixpress/dst/greyhound/core",
"//core/src/main/scala/com/wixpress/dst/greyhound/core/consumer",
"//core/src/main/scala/com/wixpress/dst/greyhound/core/consumer/domain",
"//core/src/main/scala/com/wixpress/dst/greyhound/core/consumer/retry",
"//core/src/main/scala/com/wixpress/dst/greyhound/core/metrics",
"//core/src/main/scala/com/wixpress/dst/greyhound/core/producer",
"//core/src/main/scala/com/wixpress/dst/greyhound/core/zioutils",
"//core/src/test/scala/com/wixpress/dst/greyhound/core/testkit",
"@dev_zio_izumi_reflect_2_12",
"@dev_zio_zio_2_12",
"@dev_zio_zio_managed_2_12",
"@org_apache_kafka_kafka_clients",
],
)
Loading