Trying to publish the json message on topic using schema registry but getting below error. followingspring boot approach
..
The configuration 'schema.registry.url' was supplied but isn't a known config
application yml fle
server:
port: 9080
spring:
kafka:
properties:
bootstrap.servers: server1:8080
schema.registry.url: https://bctdsdg:8081/
producer:
key-serializer: org.apache.kafka.common.serialization.StringSerializer
value-serializer: JsonSerializer.class
ssl:
keystore-location: classpath:cert.jks
keystore-password: pwd
key-password: pwd
truststore-location: classpath:dev_cacerts.jks
truststore-password: pwd
kafka configuation
@Configuration
@EnableKafka
public class KafkaConfig {
@Autowired
private KafkaProperties kafkaProperties;
@Bean
public Map<String, Object> producerConfigs() {
Map<String, Object> props = new HashMap<>();
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaProperties.getBootstrapServers());
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSerializer");
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, com.schemaregjson.serdes.JsonSerializer.class);
props.put("schema.registry.url", "https://bctdsdg:8081/");
props.putAll(kafkaProperties.getSsl().buildProperties());
props.putAll(kafkaProperties.getProperties());
return props;
}
@Bean
public ProducerFactory<String, User> producerFactory() {
return new DefaultKafkaProducerFactory<>(producerConfigs());
}
@Bean
public KafkaTemplate<String, User> kafkaTemplate() {
return new KafkaTemplate<>(producerFactory());
}
}
----------------------------------------------
@SpringBootApplication
public class SchemaregjsonApplication implements CommandLineRunner {
public static void main(String[] args) {
SpringApplication.run(SchemaregjsonApplication.class, args);
}
@Autowired
private JsonProducer jsonproducer;
User user = new User().withAge(34).withFirstname("Don").withLastname("Joe");
@Override
public void run(String... args) throws Exception {
jsonproducer.send(user);
}
}
server1:8080, so where are you getting localhost:9094? – Repetitious