search

eventuate-foundation / eventuate-cdc

Other
71 stars 31 forks source link

Support reading from sharded message table #133

Open cer opened 2 years ago

cer commented 2 years ago

Support https://github.com/eventuate-tram/eventuate-tram-core/issues/181

ktruy commented 2 years ago

Hi, I'm Hyunwoo from LG CNS I can set sharded message tables on single pipeline cdc.(eventuate.cdc.outbox.partitioning.outbox.tables) but, I can't find multi pipeline properties. How set sharded message tables on multi pipeline cdc?

cer commented 2 years ago

Hi, I'm Hyunwoo from LG CNS I can set sharded message tables on single pipeline cdc.(eventuate.cdc.outbox.partitioning.outbox.tables) but, I can't find multi pipeline properties. How set sharded message tables on multi pipeline cdc?

See https://github.com/eventuate-foundation/eventuate-cdc/blob/afc56e8dc455ef8415571beb75fbacf46929d696/eventuate-tram-cdc-connector/src/test/resources/multi-pipeline-multi-outbox.properties#L8 - it's used by this test https://github.com/eventuate-foundation/eventuate-cdc/blob/afc56e8dc455ef8415571beb75fbacf46929d696/eventuate-tram-cdc-connector/src/test/java/io/eventuate/tram/cdc/connector/MultiPipelineMultipleOutboxPollingDaoIntegrationTest.java#L55