是否需要设置任何kafka avro的架构注册表？

Question

是Kafka的新手，并且对多个教程感到非常困惑。设置任何kafka avro是否都需要架构注册表？如何使用Spring Boot-Kafka项目进行设置。

Answer 1

在spring docs中，您可以找到简单的示例来查看和了解设置spring-kafka项目的基本要求。从Maven存储库到基本的生产者和使用者配置。这里是链接：A Very, Very Quick Example

除了以上示例，要为架构注册表设置kafka API，您需要具有以下配置

对于生产者：

Properties props = new Properties();
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, KafkaAvroSerializer.class.getName());
props.put(AbstractKafkaAvroSerDeConfig.SCHEMA_REGISTRY_URL_CONFIG, "http://localhost:8081");

对于消费者：

Properties props = new Properties();
props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
props.put(ConsumerConfig.GROUP_ID_CONFIG, groupName);
props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, KafkaAvroDeserializer.class.getName());
props.put(KafkaAvroDeserializerConfig.SPECIFIC_AVRO_READER_CONFIG, false);
props.put(AbstractKafkaAvroSerDeConfig.SCHEMA_REGISTRY_URL_CONFIG, "http://localhost:8081");

当我同时使用kafka_2.11-2.1.1和SR-5.1.2时，上面的配置对我有用。希望对您有所帮助