From the Global Menu, click Controller Settings and select Controller Services tab.

Click the + icon to display the Add Controller Service dialog.

Use the Filter box to search for HortonworksSchemaRegistry and click Add.

Click the Edit icon to display the Configure Controller Service dialog.

Provide the Schema Registry URL with which you want NiFi to communicate and click Apply.

	Tip
	If you are running an Ambari-managed cluster, you can find this value in the Streaming Analytics Manager Service in Ambari for the configuration property called registry.url. The URL looks similar to http://$REGISTRY_SERVER:7788/api/v1.

Enable this HortonworksSchemaRegistry by clicking the Enable icon, selecting the Scope, and clicking Enable.

To access Controller Services configuration dialog for gobal configuration, click the Global Menu at the top right of your canvas, and select Controller Settings.

Click the + icon to display the NiFi Settings dialog.

Use the Filter box to search for the Controller Service you want to add, select that service, and click Add.

Click on your Process Group, and then right-click anyway on your canvas.

Click Configure to display the Process Group Configuration dialog.

Click the Controller Services tab, and then click + to display the Add Controller Service dialog.

Use the Filter box to search for the Controller Service you want to add, select that service, and click Add.

From the Process Group Configuration view, click the Edit icon from the right-hand column. This displays the Configure Controller Service dialog.

Click the Properties tab.

The Schema Access Strategy specifies how to obtain the schema using for interpreting FlowFile data. To ensure integration with Schema Registry, configure Schema Access Strategy with one of the following two values:

The Schema Write Strategy specifies how the schema for a record should be added to FlowFile data. To ensure integration with Schema Registry, configure Schema Write Strategy with either HWX Schema Reference Attributes orHWX Content-Encoded Schea Reference.

From the NiFi UI, drag the Processor icon onto your canvas to display the Add Processor dialog.

Use the Filter box to find the Processor you want to add. Available record-enabled processors are:

Select the Processor you want, and click Add.

Right-click the Processor on the canvas, and select Configure to display the Configure Processor dialog.

Click the Properties tab and select a Controller Service value for the Record Reader and Record Writer values.

Click OK and then Apply.

Integrate NiFi with Schema Registry.

Build your NiFi dataflow.

At the point in your dataflow where you want to either consume from a Kafka topic, or publish to a Kafka topic, add one of the following two Processors:

Configure your Kafka Processor with the following information:

Add the following text to schema-registry-serdes:

<dependency>
      <groupId>com.hortonworks.registries</groupId>
      <artifactId>schema-registry-serdes</artifactId>
</dependency>

Add the following text to the Kafka Producer configuration:

config.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
config.putAll(Collections.singletonMap(SchemaRegistryClient.Configuration.SCHEMA_REGISTRY_URL.name(), props.get(SCHEMA_REGISTRY_URL)));
config.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
config.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, KafkaAvroSerializer.class.getName());

Edit the above text with values for the following properties:

Add the following text to the Kafka Consumer configuration:

config.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
config.putAll(Collections.singletonMap(SchemaRegistryClient.Configuration.SCHEMA_REGISTRY_URL.name(), props.get(SCHEMA_REGISTRY_URL)));
config.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
config.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, KafkaAvroDeserializer.class.getName());

Edit the above text with values for the following properties: