搜索 - 腾讯云开发者社区-腾讯云

文章/答案/技术大牛

发布

来自专栏Spark学习技巧
项目实践|基于Flink的用户行为日志分析系统
/htdocs/uc_client/ chmod 777 -R /opt/lampp/htdocs/uc_server/ Discuz基本操作自定义版块进入discuz后台：http://kms mod=forumdisplay&fid=43 HTTP/1.1" 200 30647 "http://kms-4/forum.php" "Mozilla/5.0 (Windows NT 10.0; Win64 请求的资源使用的协议 200 ## (6)服务器返回给客户端的状态码，200表示成功 30647 ## (7)返回给客户端不包括响应头的字节数，如果没有信息返回，则此项应该是"-" "http://kms sinks.sink1.type = org.apache.flume.sink.kafka.KafkaSink a1.sinks.sink1.brokerList=kms-2:9092,kms-3:9092,kms Properties(); // kafka broker地址 props.put("bootstrap.servers", "kms-2:9092,kms-3:9092,kms
2.6K31发布于 2020-09-08
来自专栏Spark学习技巧
基于Canal与Flink实现数据实时增量同步(一)
canal.mq.topic=test 修改conf/canal.properties，修改内容如下： # 配置zookeeper地址 canal.zkServers =kms-2:2181,kms-3:2181,kms 默认), kafka, RocketMQ， canal.serverMode = kafka # 配置kafka地址 canal.mq.servers = kms-2:9092,kms-3:9092,kms 启动kafka控制台消费者测试 bin/kafka-console-consumer.sh --bootstrap-server kms-2:9092,kms-3:9092,kms-4:9092 --
2.8K20发布于 2020-09-08
来自专栏Spark学习技巧
基于Canal与Flink实现数据实时增量同步(二)
Properties props = new Properties(); props.setProperty("bootstrap.servers", "kms-2:9092,kms-3:9092,kms / only required for Kafka 0.8 props.setProperty("zookeeper.connect", "kms-2:2181,kms-3:2181,kms
2.2K20发布于 2020-09-08
来自专栏大数据解决方案
Flink on Hive构建流批一体数仓
properties.group.id' = 'group1', -- 消费者组 'properties.bootstrap.servers' = 'kms-2:9092,kms-3:9092,kms properties.group.id' = 'group1', -- 消费者组 'properties.bootstrap.servers' = 'kms-2:9092,kms-3:9092,kms
5.1K42发布于 2021-02-04

项目实践|基于Flink的用户行为日志分析系统

基于Canal与Flink实现数据实时增量同步(一)

基于Canal与Flink实现数据实时增量同步(二)

Flink on Hive构建流批一体数仓

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐