December 2018
Beginner
186 pages
4h 10m
English
Now, in the src/main/java/kioto/avro directory, create a file called AvroProcessor.java with the contents of Listing 5.6:
package kioto.plain;import ...public final class AvroProcessor { private Consumer<String, GenericRecord> consumer; private Producer<String, String> producer; public AvroProcessor(String brokers , String schemaRegistryUrl) { Properties consumerProps = new Properties(); consumerProps.put("bootstrap.servers", brokers); consumerProps.put("group.id", "healthcheck-processor"); consumerProps.put("key.deserializer", StringDeserializer.class); consumerProps.put("value.deserializer", KafkaAvroDeserializer.class); consumerProps.put("schema.registry.url", schemaRegistryUrl); consumer = new KafkaConsumer<>(consumerProps); ...Read now
Unlock full access