F主题的文章列表，还有F的技术要点_第1394页

Debugging Kafka connect

1.setupdebugconfigurationmainClass:org.apache.kafka.connect.cli.ConnectDistributedVMOption:-Dkafka.logs.dir=/home/lenmom/workspace/software/kafka_2.11-2.1.0/bin...

代码星球 ·2020-04-05

kafka shell file

1.startkafkaandschema_registry #!/bin/shexportKAFKA_HOME=/home/lenmom/workspace/software/confluent-community-5.1.0-2.11exportKAFKA_PROCESS_ID=$(jps|grepSup...

代码星球 ·2020-04-05

confluent kafka connect remote debugging

Tobeginwith,let'stakealookathowkafkaconnectstart.1.1 startcommand#backgroundrunningmodecd/home/lenmom/workspace/software/confluent-community-5.1.0-2.11/&am...

代码星球 ·2020-04-05

Kafka Connect REST Interface

SinceKafkaConnectisintendedtoberunasaservice,italsosupportsaRESTAPIformanagingconnectors.Bydefaultthisservicerunsonport 8083.Whenexecutedindistributedmode,...

代码星球 ·2020-04-05

building confluentinc kafka-connect-hdfs

WhenItrytocompileIgetanerroraboutamissingSNAPSHOTdependency.Theerrorlookssomethinglikethis:Failedtoexecutegoalonprojectkafka-connect-hdfs:Couldnotresolvedepende...

代码星球 ·2020-04-05

using kafkacat reset kafka offset

1.installkafkacatUbuntuapt-getinstallkafkacatCentOSinstalldeepenencyyuminstalllibrdkafka-develdownloadsourcefromgithubbuildsourceoncentos./configure<usual-co...

代码星球 ·2020-04-05

avro-1.8.1 serialize BigDecimal and Short error fix.

1.createmysqltablelikeCREATETABLE`test`(`a`tinyint(4)NOTNULLDEFAULT'0',`b`decimal(12,0)DEFAULTNULL,`c`decimal(5,0)DEFAULTNULL)ENGINE=InnoDBDEFAULTCHARSET=utf8CO...

代码星球 ·2020-04-05

Ubuntu Navicat for MySQL安装以及破解方案

首先上官网上下载LINUX版本： http://www.navicat.com/download/navicat-for-mysql1.下载navicat110_mysql_en.tar.gz文件 2.下载后解压tar文件tar -zxvf /home/rain/do...

代码星球 ·2020-04-05

Kafka Connect Architecture

KafkaConnect'sgoalofcopyingdatabetweensystemshasbeentackledbyavarietyofframeworks,manyofthemstillactivelydevelopedandmaintained.Thissectionexplainsthemotivation...

代码星球 ·2020-04-05

The usage of docker image wurstmeister/kafka

Thedockerimage wurstmeister/kafkaisthemoststaredimageforkafkainhub.docker.com,buttheuseageisrare,so inthispost,Iwouldtakesometimetotalkabouttheu...

代码星球 ·2020-04-05

kafka connect rest api

1.获取ConnectWorker信息curl-shttp://127.0.0.1:8083/|jqlenmom@M1701:~/workspace/software/kafka_2.11-2.1.0/logs$curl-shttp://127.0.0.1:8083/|jq{"version":"2.1.0","com...

代码星球 ·2020-04-05

Kafka connect in practice(3): distributed mode mysql binlog ->kafka->hive

InthepreviouspostKafkaconnectinpractice(1):standalone,Ihaveintroducedaboutthebasicsofkafkaconnect configurationanddemonstratealocalstandalonedemo.Int...

代码星球 ·2020-04-05

superrvisor application config ini

1.zookeeper[program:zookeeper]environment=JAVA_HOME="/opt/jdk1.8.0_191"process_name=%(program_name)s;进程名称directory=/home/lenmom/workspace/software/zookeeper-3.4...

代码星球 ·2020-04-05

Linux Kafka源码环境搭建

本文主要讲述的是如何搭建Kafka的源码环境，主要针对的Linux操作系统下IntelliJIDEA编译器，其余操作系统或者IDE可以类推。1.安装和配置JDK确认JDK版本至少为1.7，最好是1.8及以上。使用java-version命令来查看当前JDK的版本，示例如下：lenmom@M1701:~/workspac...

代码星球 ·2020-04-05

kafka producer实例

1.定义要发送的消息UserPOJOpackagelenmom.kafkaproducer;publicclassUser{publicStringname;publicintage;publicStringaddress;publicUser(Stringname,intage,Stringaddress){this...

代码星球 ·2020-04-05