<ruby id="bdb3f"></ruby>

    <p id="bdb3f"><cite id="bdb3f"></cite></p>

      <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
        <p id="bdb3f"><cite id="bdb3f"></cite></p>

          <pre id="bdb3f"></pre>
          <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

          <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
          <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

          <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                <ruby id="bdb3f"></ruby>

                企業??AI智能體構建引擎,智能編排和調試,一鍵部署,支持知識庫和私有化部署方案 廣告
                攔截器也是通過命名配置的組件,下面是通過配置文件創建攔截器的例子。 ```conf ############## 1. Agent初始化 ############ # agent為Agent的名字,可以隨便命名 # s1、c1、sk1是在該agent下的Source、Channel、Sink,也可以隨便命名 agent.sources = s1 agent.channels = c1 agent.sinks = sk1 ########## 攔截器配置 ################ agent.sources.s1.interceptors = i1 i2 agent.sources.s1.interceptors.il.type = org.apache.flume.interceptor.HostInterceptor$Builder # 如果 header 中已經存在同名的屬性是否保留 agent.sources.s1.interceptors.il.preserveExisting = false # 向 Event header 中添加 host 鍵值對的 key agent.sources.s1.interceptors.il.hostHeader = hostname # 這個攔截器會向每個 Event 的 header 中添加一個時間戳屬性進去,key 默認是timestamp agent.sources.s1.interceptors.i2.type = org.apache.flume.interceptor.TimestampInterceptor$Builder agent.sinks.sk1.filePrefix = FlumeData.%{CollectorHost}.%Y-%m-%d ############## 2. Source配置 ############# # 指定Source類型、主機、端口號(與上面的sink端口號相同)、通道 agent.sources.s1.type = avro agent.sources.s1.bind = hadoop101 agent.sources.s1.port = 4444 agent.sources.s1.channels = c1 ############ 3. Channel配置 ############ # 指定Channel類型 agent.channels.c1.type = memory ############ 4. Sink配置 ############# # 指定sink類型、通道 agent.sinks.sk1.type = logger agent.sinks.sk1.channel = c1 ```
                  <ruby id="bdb3f"></ruby>

                  <p id="bdb3f"><cite id="bdb3f"></cite></p>

                    <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
                      <p id="bdb3f"><cite id="bdb3f"></cite></p>

                        <pre id="bdb3f"></pre>
                        <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

                        <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
                        <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

                        <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                              <ruby id="bdb3f"></ruby>

                              哎呀哎呀视频在线观看