Unable to connect to cassandra cluster using username & passsword after upgrading to 3.0 Releasse [DATACASS-765]

[spring-projects-issues]

andyfromktm opened DATACASS-765 and commented

After upgrading to spring boot 2.3.0, our application fails to start up due to cassandra connectivity authentication issue. We are using plain text username password authentication. It seems like you need to set 'advanced.auth-provider.class' cassandra java driver connection property

---

Affects: 3.0 GA (Neumann)

[spring-projects-issues]

Mark Paluch commented

How did you configure authentication? Did you use Spring Boot's configuration properties or do you use programmatic configuration of the CqlSession?

[spring-projects-issues]

andyfromktm commented

I configured our application using 'spring.data.cassandra' properties. I tried to debug it the problem seems to be here. But did not try it. In CassandraAutoConfiguration class.

private Config cassandraConfiguration(CassandraProperties properties) {
	CassandraDriverOptions options = new CassandraDriverOptions();
	PropertyMapper map = PropertyMapper.get();
	map.from(properties.getSessionName()).whenHasText()
			.to((sessionName) -> options.add(DefaultDriverOption.SESSION_NAME, sessionName));
	map.from(properties::getUsername).whenNonNull()
			.to((username) -> options.add(DefaultDriverOption.AUTH_PROVIDER_USER_NAME, username)
					.add(DefaultDriverOption.AUTH_PROVIDER_PASSWORD, properties.getPassword()));
	map.from(properties::getCompression).whenNonNull()
			.to((compression) -> options.add(DefaultDriverOption.PROTOCOL_COMPRESSION, compression));
	mapConnectionOptions(properties, options);
	mapPoolingOptions(properties, options);
	mapRequestOptions(properties, options);
	map.from(mapContactPoints(properties))
			.to((contactPoints) -> options.add(DefaultDriverOption.CONTACT_POINTS, contactPoints));
	map.from(properties.getLocalDatacenter()).to(
			(localDatacenter) -> options.add(DefaultDriverOption.LOAD_BALANCING_LOCAL_DATACENTER, localDatacenter));
	ConfigFactory.invalidateCaches();
	return ConfigFactory.defaultOverrides().withFallback(options.build())
			.withFallback(ConfigFactory.defaultReference()).resolve();
}

 

[spring-projects-issues]

Mark Paluch commented

Thanks for the timely response. CassandraAutoConfiguration is part of Spring Boot. Can you please file a ticket in Spring Boot's issue tracker at https://github.com/spring-projects/spring-boot/issues?

[spring-projects-issues]

andyfromktm commented

OK, Thanks