Jyothsna Konisa created CASSSIDECAR-493:
-------------------------------------------
Summary: CachingSchemaStore should be reloaded when Schemastore
kafka configs are changed
Key: CASSSIDECAR-493
URL: https://issues.apache.org/jira/browse/CASSSIDECAR-493
Project: Sidecar for Apache Cassandra
Issue Type: Improvement
Reporter: Jyothsna Konisa
Schemastore configuration is stored alongside the rest of CDC's Kafka config,
there's no separate config source for it. So when that table is updated,
anything derived from it should be rebuilt, including the schema publisher.
CachingSchemaStore.loadPublisher() builds the TableSchemaPublisher from
CdcConfigImpl.kafkaConfigs() and caches it as an instance field, a one-time
snapshot, never re-read on demand. If the schema config is missing/invalid when
this runs, it throws, gets caught and logged, and publisher stays null/stale.
The only retry trigger today is ON_SIDECAR_SCHEMA_INITIALIZED.
ON_CDC_CONFIGURATION_CHANGED should also be added as a trigger.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
