java 发送数据到flume_android打点数据通过http发送到flume,再到kafka

古城微笑少年丶 2022-11-06 10:54 152阅读 0赞

\# Licensed to the Apache Software Foundation (ASF) under one

\# or more contributor license agreements. See the NOTICE file

\# distributed with this work for additional information

\# regarding copyright ownership. The ASF licenses this file

\# to you under the Apache License, Version 2.0 (the

\# "License"); you may not use this file except in compliance

\# with the License. You may obtain a copy of the License at

\#

\# http://www.apache.org/licenses/LICENSE-2.0

\#

\# Unless required by applicable law or agreed to in writing,

\# software distributed under the License is distributed on an

\# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY

\# KIND, either express or implied. See the License for the

\# specific language governing permissions and limitations

\# under the License.

agent.sources=r1

agent.sinks=k1

agent.channels=c1

agent.sources.r1.type=http

agent.sources.r1.bind=192.168.1.232

agent.sources.r1.port=5140

agent.sources.r1.channels=c1

agent.sinks.k1.type = org.apache.flume.sink.kafka.KafkaSink

agent.sinks.k1.kafka.topic = my-replicated-test

agent.sinks.k1.kafka.bootstrap.servers = 192.168.1.232:9092,192.168.1.233:9092,192.168.1.234:9092

agent.sinks.k1.kafka.flumeBatchSize = 100

agent.sinks.k1.kafka.producer.acks = 1

agent.sinks.k1.kafka.producer.linger.ms = 1

agent.sinks.k1.serializer.class=kafka.serializer.StringEncoder

agent.sinks.k1.channel=c1

agent.channels.c1.type=memory

agent.channels.c1.capacity=1000

agent.channels.c1.transactionCapacity=100

发表评论取消回复

表情：

评论列表（有 0 条评论，152人围观）

还没有评论，来说两句吧...

相关阅读

相关 Flume均匀发送数据到kafka的partition配置UUID Interceptor生成key的坑

一、需求 Flume向kafka发送数据时，同一个flume发送到kafka的数据总是固定在某一个partition中。而业务需求是发送的数据在所有的partition平

àì夳堔傛蜴生んèń/ 2023年06月30日 14:56/ 0 赞/ 16 阅读

相关 python模拟发送json数据到logstash

一、模拟日志数据生成脚本 json\_log.py !/usr/bin/python -- coding: UTF-8 -- import da

Bertha 。/ 2023年02月16日 12:06/ 0 赞/ 40 阅读

相关 java 发送数据到flume_android打点数据通过http发送到flume,再到kafka

\ Licensed to the Apache Software Foundation (ASF) under one \ or more contributor lice

古城微笑少年丶/ 2022年11月06日 10:54/ 0 赞/ 153 阅读

相关 nifi发送消息到Kafka--示例

数据流图： ![Image 1][]![Center][] 示例说明：从Ftp指定目录抽取文件，将文件内容更换为文件名和文件抽取路径，并将此内容发送到kafka主题为t

妖狐艹你老母/ 2022年07月13日 07:21/ 0 赞/ 241 阅读

相关 linux集成 kafka数据通过flume发送到hadoop

上一篇文章《[ linux安装flume和集成kafka测试][linux_flume_kafka]》，我们介绍了flume安装和集成数据到kafka，本篇文章我们将集成kaf

﹏ヽ暗。殇╰゛Y/ 2022年06月15日 03:55/ 0 赞/ 179 阅读

相关使用httpwebrequest发送数据到网站

怎样通过HttpWebRequest 发送 POST 请求到一个网页服务器？例如编写个程序实现自动用户登录，自动提交表单数据到网站等。假如某个页面有个如下的表单（Form

墨蓝/ 2022年04月01日 09:26/ 0 赞/ 226 阅读

相关 flume数据采集到kafka

agent.sources = s1 agent.channels = c1 agent.sinks = k1 agent.sourc

超、凢脫俗/ 2022年03月16日 08:36/ 0 赞/ 348 阅读

相关接收canal消息发送到kafka

在Canal消息订阅端 binlog-server-new项目中，完成了接收canal消息，并发送到kafka 我们需要写一个Canal客户端，CanalClient，来监听

柔情只为你懂/ 2022年02月01日 04:01/ 0 赞/ 520 阅读

相关 ble编程－外设发送数据到中心

一、外设 1.在外设的.h文件中定义如下 ![ExpandedBlockStart.gif][] 1 //周边管理者 2 3 @property (nona

ゞ浴缸里的玫瑰/ 2021年11月02日 06:44/ 0 赞/ 244 阅读

相关 js获取麦克风数据通过websocket发送到后台

实现效果：PC端通过麦克风录音，通过 WebSocket实时传递到后台原始每包数据过于大，后台不能接收，需要分包处理，每包最大1024 原始采样率为4800

灰太狼/ 2021年09月01日 04:23/ 0 赞/ 1245 阅读