- props.put("bootstrap.servers", properties.bootstrapServers);
- props.put("schema.registry.url", properties.schemaRegistryUrl);
- props.put("key.serializer", UUIDSerializer.class.getName());
- props.put("value.serializer", SpecificAvroSerializer.class.getName());
+ props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, properties.bootstrapServers);
+ props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, UUIDSerializer.class);
+ props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);