This is an automated email from the ASF dual-hosted git repository. ppkarwasz pushed a commit to branch docs/move-flume-site in repository https://gitbox.apache.org/repos/asf/logging-flume.git
commit 4e4f4b0f66711a6ba8303b42941ef13e4f49f087 Author: Ralph Goers <[email protected]> AuthorDate: Sat Oct 8 12:43:13 2022 -0700 Add info about Kafka headers and timestamp --- source/sphinx/FlumeUserGuide.rst | 8 ++++++++ source/sphinx/security.rst | 2 +- 2 files changed, 9 insertions(+), 1 deletion(-) diff --git a/source/sphinx/FlumeUserGuide.rst b/source/sphinx/FlumeUserGuide.rst index b0dcf928..45632aa0 100644 --- a/source/sphinx/FlumeUserGuide.rst +++ b/source/sphinx/FlumeUserGuide.rst @@ -1814,6 +1814,10 @@ topicHeader topic Defines the name of the header from, if the ``setTopicHeader`` property is set to ``true``. Care should be taken if combining with the Kafka Sink ``topicHeader`` property so as to avoid sending the message back to the same topic in a loop. +timestampHeader -- If present the Kafka message timestamp value will be copied into the specified Flume header name. +header.NAME -- Used to identify which headers from the Kafka message should be added as a FLume header. The value + of NAME should match the Flume header name and the value should be the name of the header to be used + as the Kafka header name. kafka.consumer.security.protocol PLAINTEXT Set to SASL_PLAINTEXT, SASL_SSL or SSL if writing to Kafka using some level of security. See below for additional info on secure setup. *more consumer security props* If using SASL_PLAINTEXT, SASL_SSL or SSL refer to `Kafka security <http://kafka.apache.org/documentation.html#security>`_ for additional properties that need to be set on consumer. @@ -3441,6 +3445,10 @@ partitionIdHeader -- When set, the sink will allowTopicOverride true When set, the sink will allow a message to be produced into a topic specified by the ``topicHeader`` property (if provided). topicHeader topic When set in conjunction with ``allowTopicOverride`` will produce a message into the value of the header named using the value of this property. Care should be taken when using in conjunction with the Kafka Source ``topicHeader`` property to avoid creating a loopback. +timestampHeader -- The header containing the caller provided timestamp value to use. If not provided the current time will + be used. +header.NAME -- Used to identify which headers from the Flume Event should be passed to Kafka. The value of NAME should match + the Flume header name and the value should be the name of the header to be used as the Kafka header name. kafka.producer.security.protocol PLAINTEXT Set to SASL_PLAINTEXT, SASL_SSL or SSL if writing to Kafka using some level of security. See below for additional info on secure setup. *more producer security props* If using SASL_PLAINTEXT, SASL_SSL or SSL refer to `Kafka security <http://kafka.apache.org/documentation.html#security>`_ for additional properties that need to be set on producer. diff --git a/source/sphinx/security.rst b/source/sphinx/security.rst index ee4ca840..be6fae26 100644 --- a/source/sphinx/security.rst +++ b/source/sphinx/security.rst @@ -15,7 +15,7 @@ If you have encountered an unlisted security vulnerability or other unexpected b `CVE-2022-34916 <https://cve.mitre.org/cgi-bin/cvename.cgi?name=CVE-2022-34916>`__: Apache Flume vulnerable to a JNDI RCE in JMSMessageConsumer. +------------------------------------------------------------------------------------+--------------------------------------------------------------------------+ -| `CVE-2022-25167 <https://cve.mitre.org/cgi-bin/cvename.cgi?name=CVE-2022-34916>`__ | Deserialization of Untrusted Data | +| `CVE-2022-34916 <https://cve.mitre.org/cgi-bin/cvename.cgi?name=CVE-2022-34916>`__ | Deserialization of Untrusted Data | +====================================================================================+==========================================================================+ | Severity | Moderate | +------------------------------------------------------------------------------------+--------------------------------------------------------------------------+
