[feat][io] Cassandra sink: support authenticated clusters by david-streamlio · Pull Request #136 · apache/pulsar-connectors

Run tests: cassandra/src/test/java/org/apache/pulsar/io/cassandra/CassandraStringSinkTest.java#L48

[deprecation] CassandraContainer in org.testcontainers.containers has been deprecated

Run tests: cassandra/src/test/java/org/apache/pulsar/io/cassandra/CassandraStringSinkTest.java#L48

[deprecation] CassandraContainer in org.testcontainers.containers has been deprecated

Run tests: dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/DynamoDBSource.java#L92

[deprecation] KinesisClientLibConfiguration(String,String,AWSCredentialsProvider,String) in KinesisClientLibConfiguration has been deprecated

Run tests: canal/src/main/java/org/apache/pulsar/io/canal/CanalStringSource.java#L59

[deprecation] FixedDateFormat in org.apache.logging.log4j.core.util.datetime has been deprecated

Run tests: alluxio/src/test/java/org/apache/pulsar/io/alluxio/sink/AlluxioSinkTest.java#L138

[unchecked] unchecked conversion

Run tests: alluxio/src/test/java/org/apache/pulsar/io/alluxio/sink/AlluxioSinkTest.java#L117

[unchecked] unchecked conversion

Run tests: alluxio/src/main/java/org/apache/pulsar/io/alluxio/sink/AlluxioSink.java#L300

[unchecked] unchecked cast

Run tests: alluxio/src/main/java/org/apache/pulsar/io/alluxio/sink/AlluxioSink.java#L296

[unchecked] unchecked conversion

Run tests: alluxio/src/main/java/org/apache/pulsar/io/alluxio/sink/AlluxioSink.java#L99

[deprecation] set(PropertyKey,String) in InstancedConfiguration has been deprecated

Run tests: alluxio/src/main/java/org/apache/pulsar/io/alluxio/sink/AlluxioSink.java#L96

[deprecation] set(PropertyKey,String) in InstancedConfiguration has been deprecated

Navigation Menu