You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: pipeline/outputs/kafka-rest-proxy.md
+23-21Lines changed: 23 additions & 21 deletions
Original file line number
Diff line number
Diff line change
@@ -1,40 +1,42 @@
1
-
# Kafka REST Proxy
1
+
# Kafka REST proxy
2
2
3
-
The **kafka-rest** output plugin, allows to flush your records into a [Kafka REST Proxy](http://docs.confluent.io/current/kafka-rest/docs/index.html) server. The following instructions assumes that you have a fully operational Kafka REST Proxy and Kafka services running in your environment.
3
+
The _Kafka rest_ (`kafka-rest`) output plugin lets you flush your records into a [Kafka REST Proxy](http://docs.confluent.io/current/kafka-rest/docs/index.html) server. The following instructions assume you have an operational Kafka REST Proxy and Kafka services running in your environment.
4
4
5
-
## Configuration Parameters
5
+
## Configuration parameters
6
+
7
+
This plugin supports the following parameters:
6
8
7
9
| Key | Description | default |
8
10
| :--- | :--- | :--- |
9
-
| Host | IP address or hostname of the target Kafka REST Proxy server | 127.0.0.1 |
10
-
| Port | TCP port of the target Kafka REST Proxy server | 8082 |
11
-
| Topic | Set the Kafka topic | fluent-bit |
12
-
| Partition | Set the partition number\(optional\)||
13
-
|Message\_Key| Set a message key\(optional\)||
14
-
|Time\_Key| The Time\_Key property defines the name of the field that holds the record timestamp. |@timestamp|
15
-
|Time\_Key\_Format| Defines the format of the timestamp. | %Y-%m-%dT%H:%M:%S |
16
-
|Include\_Tag\_Key| Append the Tag name to the final record. | Off |
17
-
|Tag\_Key| If Include\_Tag\_Key is enabled, this property defines the key name for the tag. |\_flb-key |
18
-
| Workers | The number of [workers](../../administration/multithreading.md#outputs) to perform flush operations for this output. |`0`|
11
+
|`Host`| IP address or hostname of the target Kafka REST Proxy server.|`127.0.0.1`|
12
+
|`Port`| TCP port of the target Kafka REST Proxy server.|`8082`|
13
+
|`Topic`| Set the Kafka topic.|`fluent-bit`|
14
+
|`Partition`|Optional. Set the partition number. |_none_|
15
+
|`Message_Key`|Optional. Set a message key. |_none_|
16
+
|`Time_Key`| The `Time_Key` property defines the name of the field that holds the record timestamp. |`@timestamp`|
17
+
|`Time_Key_Format`| Defines the format of the timestamp. |`%Y-%m-%dT%H:%M:%S`|
18
+
|`Include_Tag_Key`| Append the Tag name to the final record. |`Off`|
19
+
|`Tag_Key`| If `Include_Tag_Key` is enabled, this property defines the key name for the tag. |`_flb-key`|
20
+
|`Workers`| The number of [workers](../../administration/multithreading.md#outputs) to perform flush operations for this output. |`0`|
19
21
20
22
### TLS / SSL
21
23
22
24
The Kafka REST Proxy output plugin supports TLS/SSL.
23
25
For more details about the properties available and general configuration, see [TLS/SSL](../../administration/transport-security.md).
24
26
25
-
## Getting Started
27
+
## Get started
26
28
27
-
In order to insert records into a Kafka REST Proxy service, you can run the plugin from the command line or through the configuration file:
29
+
To insert records into a Kafka REST Proxy service, you can run the plugin from the command line or through the configuration file.
28
30
29
-
### Command Line
31
+
### Command line
30
32
31
-
The **kafka-rest**plugin, can read the parameters from the command line in two ways, through the **-p** argument \(property\), e.g:
33
+
The Kafka REST plugin can read the parameters from the command line through the `-p` argument (property):
32
34
33
35
```shell
34
36
fluent-bit -i cpu -t cpu -o kafka-rest -p host=127.0.0.1 -p port=8082 -m '*'
35
37
```
36
38
37
-
### Configuration File
39
+
### Configuration file
38
40
39
41
In your main configuration file append the following:
40
42
@@ -45,8 +47,8 @@ In your main configuration file append the following:
0 commit comments