Chris Richardson

Results 128 issues of Chris Richardson

The [docs](https://fluxcd.io/flagger/usage/webhooks/#load-testing) use: ``` cmd: "hey -z 1m -q 10 -c 2 -m POST -d '{test: 2}' http://podinfo-canary.test:9898/echo" ``` I'm confused by the use of the `podinfo-canary.test`, which references the...

See https://github.com/eventuate-examples/eventuate-tram-examples-perf-test/blob/cb06a7fbc4bcd5353b243fcadf6d1a8679007133/consumer/src/main/java/io/eventuate/tram/examples/performance/subscriber/ConsumerMain.java#L18 The service uses `SqlTableBasedDuplicateMessageDetector` via `"io.eventuate.tram.core:eventuate-tram-spring-consumer-jdbc"` Solution: `TramConsumerJdbcAutoConfiguration` should `@Import(EventuateCommonJdbcOperationsConfiguration.class)`

In order to improve scalability of Producer and CDC, shard the message table using `Message.PARTITION_ID` (i.e. domain event aggregate ID): * Multiple message tables - `MESSAGE{hash(destination, partitionID) % numberOfOutboxTables}` -...

For example, an anonymous subscriber that wants future messages. Currently, `auto.offset.reset=latest` https://github.com/eventuate-foundation/eventuate-messaging-kafka/blob/b7b618dff09401cf12a51b7b59dd4de0d2771e2d/eventuate-messaging-kafka-basic-consumer/src/main/java/io/eventuate/messaging/kafka/basic/consumer/ConsumerPropertiesFactory.java#L15

https://github.com/eventuate-tram/eventuate-tram-core/blob/03105f51442803279b20a9395adb97787b63b5af/eventuate-tram-commands-db-broker-integration-test/build.gradle#L12

repeated failures: https://app.circleci.com/pipelines/github/eventuate-tram/eventuate-tram-sagas/116/workflows/cde3d011-1e42-4b78-867d-407f2ed8a57e/jobs/582 `io.eventuate.examples.tram.sagas.ordersandcustomers.spring.reactive.integrationtests.CustomersAndOrdersIntegrationTest` ``` io.eventuate.util.test.async.EventuallyException: Failed after 60 iterations every 500 milliseconds at io.eventuate.util.test.async.Eventually.eventuallyReturning(Eventually.java:70) at io.eventuate.util.test.async.Eventually.eventually(Eventually.java:37) at io.eventuate.util.test.async.Eventually.eventually(Eventually.java:33) at io.eventuate.examples.tram.sagas.ordersandcustomers.spring.reactive.integrationtests.CustomersAndOrdersIntegrationTest.assertOrderState(CustomersAndOrdersIntegrationTest.java:83) at io.eventuate.examples.tram.sagas.ordersandcustomers.spring.reactive.integrationtests.CustomersAndOrdersIntegrationTest.shouldReject(CustomersAndOrdersIntegrationTest.java:65) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)...