Kafka Brokers |
Provide a comma-separated list of known Kafka Brokers in the format
<host>:<port> . |
Docs-messaging-broker1.cdf-docs.a465-9q4k.cloudera.site:9093,
docs-messaging-broker2.cdf-docs.a465-9q4k.cloudera.site:9093,
docs-messaging-broker3.cdf-docs.a465-9q4k.cloudera.site:9093
|
Topic Name(s) |
Enter the name of the Kafka topic from which you want to get
data. |
customer |
Topic Name Format |
Specify whether the topics are a comma separated list of topic names or
a single regular expression. |
names |
Record Reader |
Specify the record reader to use for incoming flowfiles. This can be a
range of data formats. |
AvroReader |
Record Writer |
Specify the format you want to use to serialize data before for
sending it to the data target.
|
AvroRecordSetWriter |
Honor Transactions |
Specify whether or not NiFi should honor transactional guarantees when
communicating with Kafka. |
false |
Security Protocol |
Specify the protocol used to communicate with brokers. This value
corresponds to Kafka's 'security.protocol' property. |
SASL_SSL |
SASL Mechanism |
Specify the SASL mechanism to be used for authentication. This value
corresponds to Kafka's 'sasl.mechanism' property. |
plain |
Username |
Specify the username when the SASL Mechanism is PLAIN or
SCRAM-SHA-256. |
srv_nifi-solr-ingest |
Password |
Specify the password for the given username when the SASL Mechanism is
PLAIN or SCRAM-SHA-256. |
Password1! |
SSL Context Service |
Specify the SSL Context Service to be used for communicating with
Kafka. |
default |
Group ID |
Specify the Group ID used to identify consumers that are within the
same consumer group. This value corresponds to Kafka's
group.id property. |
nifi-solr-ingest |