Skip to content

Tolerate breaking change to IsolationLevel in kafka-clients 2.5 #20811

@garyrussell

Description

@garyrussell

KafkaProperties currently has

	/**
	 * Isolation level for reading messages that have been written transactionally.
	 */
	private IsolationLevel isolationLevel = IsolationLevel.READ_UNCOMMITTED;

and

		map.from(() -> getIsolationLevel().name().toLowerCase(Locale.ROOT))
				.to(properties.in(ConsumerConfig.ISOLATION_LEVEL_CONFIG));

Please change it to use the String literal read_uncommitted instead.

It is not clear (there is some doubt) that the 2.5.0 clients will be available in time for the Boot RC this month.

Unfortunately, they have moved the IsolationLevel class up to the next package.

In order to allow us to override spring-kafka and kafka-clients to 2.5.0 with Boot 2.3, we can't have this hard reference to the class in the 2.4.x location.

Metadata

Metadata

Assignees

Labels

Type

No type

Projects

No projects

Milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions