Set Up Kafka Open Collector and Beats
The Kafka Open Collector runs in a native
container, and provides the foundation functionality. See "Open
Collector Installation and User Guide" in Explore More for instructions.
Initialize Kafka Beat
Kafka combines key capabilities to publish
(write), subscribe to (read), store and process streams for logs, as they
occur. Refer to the following table for OCI stream information to
configure.
OCI Stream Fields | LogRhythm Kafka Beat Fields Name | LogRhythm Kafka Beat Field Value |
---|---|---|
Stream Name | Enter the Kafka topic name from which you want to collect data. | OCI Stream Name. For example:
demo-stream-01 |
Stream OCID | Enter the consumer ID for the Kafka Beat instance. | OCI Stream OCID. For example:
ocid1.stream.oc1.ap-region-1.amaaaaaajiuah5vxejqv2jjj7dyea |
Bootstrap Servers | Enter the Kafka broker as
ip:port .
|
OCI bootstrap server with port. For example:
swqq.streaming.ap-region-1.oci.oraclecloud.com:9092 |
Security Protocol | Default Authentication Mechanism value. | SASL_SSL |
Security Mechanism | Default SASL_SSL mechanism value. | PLAIN |
Tenancy/user_id/streampool_ocid |
Enter username for SASL authentication. | Username from OCI SASL Connection Strings field. For example:
demotenancy/user1@demo.com/ocid1.streampool.oc1.ap-region-1.amaaa2fct5faqbzitguue4korjk62ct6swqs2ijhusjq |
AUTH_TOKEN | Enter password for SASL authentication. | OCI Auth token of user. For example:
ct5faqbzitguue4 |
Refer to "Initialize Kafka Beat" in Explore More for more information.