This is an automated email from the ASF dual-hosted git repository.
jyothsnakonisa pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra-sidecar.git
from ede61f1d CASSSIDECAR-442: Add pre-test environment checks and
aggregate jacoco report
new 4c09917c CASSSIDECAR-455: Fix breaking changes for Analytics 0.4.0
new c2f352f2 CASSSIDECAR-456: Fix CDC resource leaks: thread leaks, Kafka
resource cleanup, singleton SidecarCdcClient
new 9f8832b6 CASSSIDECAR-457: Fix CDC message loss during Sidecar restarts
new 27ea91cd CASSSIDECAR-458: Add SidecarReplicationFactorSupplier for
live replication factor lookups
new d67a5e3b CASSSIDECAR-459: Fix ON_CDC_CACHE_WARMED_UP not fired when
schema publisher fails
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
CHANGES.txt | 5 +
gradle.properties | 2 +-
integration-framework/build.gradle | 1 +
.../sidecar/testing/TestCdcPublisher.java | 50 ++--
.../cassandra/sidecar/cdc/CdcIntegrationTest.java | 3 +
...SharedClusterCdcSidecarIntegrationTestBase.java | 49 ++--
server/build.gradle | 4 +
.../cassandra/bridge/CassandraBridgeFactory.java | 18 +-
.../cassandra/sidecar/cdc/CachingSchemaStore.java | 85 +++++--
.../cassandra/sidecar/cdc/CdcAvroSerializer.java | 42 ---
.../apache/cassandra/sidecar/cdc/CdcConfig.java | 16 ++
.../cassandra/sidecar/cdc/CdcConsumerEntry.java | 61 +++++
.../cassandra/sidecar/cdc/CdcEventConsumer.java | 6 +
.../apache/cassandra/sidecar/cdc/CdcManager.java | 180 ++++++-------
.../apache/cassandra/sidecar/cdc/CdcPublisher.java | 199 +++++++--------
.../cassandra/sidecar/cdc/SidecarCdcOptions.java | 9 +
.../sidecar/cdc/SidecarClientSecretsProvider.java | 65 +++++
.../cdc/SidecarReplicationFactorSupplier.java | 73 ++++++
.../cassandra/sidecar/modules/CdcModule.java | 104 ++++++--
.../sidecar/cdc/CdcConsumerEntryTest.java | 73 ++++++
.../cassandra/sidecar/cdc/CdcManagerTest.java | 76 +++---
.../cassandra/sidecar/cdc/CdcPublisherTests.java | 282 +++------------------
...java => SidecarClientSecretsProviderTests.java} | 191 +++-----------
.../cdc/SidecarReplicationFactorSupplierTest.java | 107 ++++++++
24 files changed, 906 insertions(+), 795 deletions(-)
delete mode 100644
server/src/main/java/org/apache/cassandra/sidecar/cdc/CdcAvroSerializer.java
create mode 100644
server/src/main/java/org/apache/cassandra/sidecar/cdc/CdcConsumerEntry.java
create mode 100644
server/src/main/java/org/apache/cassandra/sidecar/cdc/SidecarClientSecretsProvider.java
create mode 100644
server/src/main/java/org/apache/cassandra/sidecar/cdc/SidecarReplicationFactorSupplier.java
create mode 100644
server/src/test/java/org/apache/cassandra/sidecar/cdc/CdcConsumerEntryTest.java
copy
server/src/test/java/org/apache/cassandra/sidecar/cdc/{CdcPublisherTests.java
=> SidecarClientSecretsProviderTests.java} (51%)
create mode 100644
server/src/test/java/org/apache/cassandra/sidecar/cdc/SidecarReplicationFactorSupplierTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
