();
- config.put(AbstractKafkaAvroSerDeConfig.SCHEMA_REGISTRY_URL_CONFIG, schemaRegistryUrl);
+ config.put(KafkaAvroDeserializerConfig.SCHEMA_REGISTRY_URL_CONFIG, schemaRegistryUrl);
if (schemaRegistryAuth != null) {
- config.put(AbstractKafkaAvroSerDeConfig.BASIC_AUTH_CREDENTIALS_SOURCE, "USER_INFO");
- config.put(AbstractKafkaAvroSerDeConfig.USER_INFO_CONFIG, schemaRegistryAuth);
+ config.put(KafkaAvroDeserializerConfig.BASIC_AUTH_CREDENTIALS_SOURCE, "USER_INFO");
+ config.put(KafkaAvroDeserializerConfig.USER_INFO_CONFIG, schemaRegistryAuth);
}
final var kafkaAvroSerializer = new KafkaAvroSerializer();
kafkaAvroSerializer.configure(config, false);
diff --git a/src/main/resources/templates/error.ftlh b/src/main/resources/templates/error.ftlh
index af10b2ad..dcb2fee6 100644
--- a/src/main/resources/templates/error.ftlh
+++ b/src/main/resources/templates/error.ftlh
@@ -1,14 +1,14 @@
<#import "/spring.ftl" as spring />
<#import "lib/template.ftlh" as template>
-<@template.header "${error.error}"/>
-${error.error}
+<@template.header "${error['message']!''}"/>
+${error['message']}
-<#if error.trace??>
+<#if error['trace']??>
Stack trace
- ${error.trace}
+ ${error['trace']}
<#else>
#if>
diff --git a/src/test/java/kafdrop/AbstractIntegrationTest.java b/src/test/java/kafdrop/AbstractIntegrationTest.java
index 4bf80c80..887d8fbd 100644
--- a/src/test/java/kafdrop/AbstractIntegrationTest.java
+++ b/src/test/java/kafdrop/AbstractIntegrationTest.java
@@ -16,7 +16,7 @@
@ContextConfiguration(initializers = AbstractIntegrationTest.Initializer.class)
abstract class AbstractIntegrationTest {
static class Initializer implements ApplicationContextInitializer {
- static KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka").withTag("5.4.3"));
+ static KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka").withTag("7.7.7"));
public static Map getProperties() {
Startables.deepStart(List.of(kafka)).join();