November 2017
Beginner to intermediate
290 pages
7h 34m
English
The application is configured via the properties.xml file, in the resources/META-INF directory, and includes the following elements:
The first two are straightforward:
<property>
<name>apex.operator.KafkaInput.prop.topics</name>
<value>ETLTopic</value>
</property><property>
<name>apex.operator.KafkaInput.prop.clusters</name>
<value>localhost:9092</value> <!-- broker (NOT zookeeper) address -->
</property>
The topics property of the KafkaInput operator defines the topic for input records, and the ...
Read now
Unlock full access