Skip to content

Commit 6876694

Browse files
garyrussellartembilan
authored andcommitted
Fix raw types warning in a new code
* Fix `xref` path in a `validation.adoc`
1 parent 8b15468 commit 6876694

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

spring-kafka-docs/src/main/antora/modules/ROOT/pages/kafka/receiving-messages/validation.adoc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -81,4 +81,4 @@ Starting with version 2.5.11, validation now works on payloads for `@KafkaHandle
8181
See xref:kafka/receiving-messages/class-level-kafkalistener.adoc[`@KafkaListener` on a Class].
8282

8383
Starting with version 3.1, you can perform validation in an `ErrorHandlingDeserializer` instead.
84-
See xref:../serdes.adoc#error-handling-deserializer[Using `ErrorHandlingDeserializer`] for more information.
84+
See xref:kafka/serdes.adoc#error-handling-deserializer[Using `ErrorHandlingDeserializer`] for more information.

spring-kafka/src/main/java/org/springframework/kafka/config/KafkaListenerEndpointRegistrar.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -189,7 +189,7 @@ public void afterPropertiesSet() {
189189
protected void registerAllEndpoints() {
190190
synchronized (this.endpointDescriptors) {
191191
for (KafkaListenerEndpointDescriptor descriptor : this.endpointDescriptors) {
192-
if (descriptor.endpoint instanceof MultiMethodKafkaListenerEndpoint mmkle
192+
if (descriptor.endpoint instanceof MultiMethodKafkaListenerEndpoint<?, ?> mmkle
193193
&& this.validator != null) {
194194
mmkle.setValidator(this.validator);
195195
}

spring-kafka/src/main/java/org/springframework/kafka/support/serializer/ErrorHandlingDeserializer.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -166,7 +166,7 @@ private void setupFunction(Map<String, ?> configs, String configKey) {
166166
if (configs.containsKey(configKey)) {
167167
try {
168168
Object value = configs.get(configKey);
169-
Class<?> clazz = value instanceof Class cls ? cls : ClassUtils.forName((String) value, null);
169+
Class<?> clazz = value instanceof Class<?> cls ? cls : ClassUtils.forName((String) value, null);
170170
Assert.isTrue(Function.class.isAssignableFrom(clazz), "'function' must be a 'Function ', not a "
171171
+ clazz.getName());
172172
this.failedDeserializationFunction = (Function<FailedDeserializationInfo, T>)
@@ -182,7 +182,7 @@ private void setupValidator(Map<String, ?> configs) {
182182
if (configs.containsKey(VALIDATOR_CLASS) && this.validator == null) {
183183
try {
184184
Object value = configs.get(VALIDATOR_CLASS);
185-
Class<?> clazz = value instanceof Class cls ? cls : ClassUtils.forName((String) value, null);
185+
Class<?> clazz = value instanceof Class<?> cls ? cls : ClassUtils.forName((String) value, null);
186186
Object instance = clazz.getDeclaredConstructor().newInstance();
187187
Assert.isInstanceOf(Validator.class, instance, "'validator' must be a 'Validator', not a ");
188188
this.validator = (Validator) instance;

0 commit comments

Comments
 (0)