This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-site.git
The following commit(s) were added to refs/heads/main by this push:
new 2796313f2f1 Remove Pulsar IO Flume connector (#1067)
2796313f2f1 is described below
commit 2796313f2f1c706b0e150c82293be7db51652827
Author: Lari Hotari <[email protected]>
AuthorDate: Mon Mar 16 11:03:42 2026 +0200
Remove Pulsar IO Flume connector (#1067)
---
data/connectors.js | 6 -----
docs/io-connectors.md | 12 ----------
docs/io-flume-sink.md | 59 -------------------------------------------------
docs/io-flume-source.md | 59 -------------------------------------------------
4 files changed, 136 deletions(-)
diff --git a/data/connectors.js b/data/connectors.js
index 76522eb02ab..de6ca661303 100644
--- a/data/connectors.js
+++ b/data/connectors.js
@@ -77,12 +77,6 @@ module.exports = [
type: 'Source',
link: 'https://github.com/apache/pulsar/tree/master/pulsar-io/file'
},
- {
- name: 'flume',
- longName: 'Flume source and sink',
- type: 'Source and sink',
- link: 'https://flume.apache.org/'
- },
{
name: 'hbase',
longName: 'HBase sink',
diff --git a/docs/io-connectors.md b/docs/io-connectors.md
index cd355a9f943..01f43bba038 100644
--- a/docs/io-connectors.md
+++ b/docs/io-connectors.md
@@ -77,12 +77,6 @@ Pulsar has various source connectors, which are sorted
alphabetically as below.
* [Java
class](https://github.com/apache/pulsar/blob/master/pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileSource.java)
-### Flume
-
-* [Configuration](io-flume-source.md#configuration)
-
-* [Java
class](https://github.com/apache/pulsar/blob/master/pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/FlumeConnector.java)
-
### Kafka
* [Configuration](io-kafka-source.md#configuration)
@@ -163,12 +157,6 @@ Pulsar has various sink connectors, which are sorted
alphabetically as below.
* [Java
class](https://github.com/apache/pulsar/blob/master/pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchSink.java)
-### Flume
-
-* [Configuration](io-flume-sink.md#configuration)
-
-* [Java
class](https://github.com/apache/pulsar/blob/master/pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/sink/StringSink.java)
-
### HBase
* [Configuration](io-hbase-sink.md#configuration)
diff --git a/docs/io-flume-sink.md b/docs/io-flume-sink.md
deleted file mode 100644
index 511746bfb3b..00000000000
--- a/docs/io-flume-sink.md
+++ /dev/null
@@ -1,59 +0,0 @@
----
-id: io-flume-sink
-title: Flume sink connector
-sidebar_label: "Flume sink connector"
----
-
-:::note
-
-You can download all the Pulsar connectors on [download
page](pathname:///download).
-
-:::
-
-The Flume sink connector pulls messages from Pulsar topics to logs.
-
-## Configuration
-
-The configuration of the Flume sink connector has the following properties.
-
-### Property
-
-| Name | Type|Required | Default | Description
-|------|----------|----------|---------|-------------|
-`name`|String|true|"" (empty string)|The name of the agent.
-`confFile`|String|true|"" (empty string)|The configuration file.
-`noReloadConf`|Boolean|false|false|Whether to reload configuration file if
changed.
-`zkConnString`|String|true|"" (empty string)|The ZooKeeper connection.
-`zkBasePath`|String|true|"" (empty string)|The base path in ZooKeeper for
agent configuration.
-
-### Example
-
-Before using the Flume sink connector, you need to create a configuration file
through one of the following methods.
-
-> For more information about the `sink.conf` in the example below, see
[here](https://github.com/apache/pulsar/blob/master/pulsar-io/flume/src/main/resources/flume/sink.conf).
-
-* JSON
-
- ```json
- {
- "configs": {
- "name": "a1",
- "confFile": "sink.conf",
- "noReloadConf": "false",
- "zkConnString": "",
- "zkBasePath": ""
- }
- }
- ```
-
-* YAML
-
- ```yaml
- configs:
- name: a1
- confFile: sink.conf
- noReloadConf: false
- zkConnString: ""
- zkBasePath: ""
- ```
-
diff --git a/docs/io-flume-source.md b/docs/io-flume-source.md
deleted file mode 100644
index 8a1f1d323b2..00000000000
--- a/docs/io-flume-source.md
+++ /dev/null
@@ -1,59 +0,0 @@
----
-id: io-flume-source
-title: Flume source connector
-sidebar_label: "Flume source connector"
----
-
-:::note
-
-You can download all the Pulsar connectors on [download
page](pathname:///download).
-
-:::
-
-The Flume source connector pulls messages from logs to Pulsar topics.
-
-## Configuration
-
-The configuration of the Flume source connector has the following properties.
-
-### Property
-
-| Name | Type|Required | Default | Description
-|------|----------|----------|---------|-------------|
-`name`|String|true|"" (empty string)|The name of the agent.
-`confFile`|String|true|"" (empty string)|The configuration file.
-`noReloadConf`|Boolean|false|false|Whether to reload configuration file if
changed.
-`zkConnString`|String|true|"" (empty string)|The ZooKeeper connection.
-`zkBasePath`|String|true|"" (empty string)|The base path in ZooKeeper for
agent configuration.
-
-### Example
-
-Before using the Flume source connector, you need to create a configuration
file through one of the following methods.
-
-> For more information about the `source.conf` in the example below, see
[here](https://github.com/apache/pulsar/blob/master/pulsar-io/flume/src/main/resources/flume/source.conf).
-
-* JSON
-
- ```json
- {
- "configs": {
- "name": "a1",
- "confFile": "source.conf",
- "noReloadConf": "false",
- "zkConnString": "",
- "zkBasePath": ""
- }
- }
- ```
-
-* YAML
-
- ```yaml
- configs:
- name: a1
- confFile: source.conf
- noReloadConf: false
- zkConnString: ""
- zkBasePath: ""
- ```
-
