SeaTunnel本地运行以及kafka发送到redis说明-Toy模板网

这篇具有很好参考价值的文章主要介绍了SeaTunnel本地运行以及kafka发送到redis说明。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

下载

Seatunnel2.3.1源码

Idea中的目录结构

SeaTunnel本地运行以及kafka发送到redis说明,大数据,kafka,redis,java

编译

通过maven进行代码编译

SeaTunnel本地运行以及kafka发送到redis说明,大数据,kafka,redis,java

编译命令

mvn clean package -pl seatunnel-dist -am -Dmaven.test.skip=true

编译单个模块命令

mvn clean package -pl seatunnel-examples/seatunnel-engine-examples -am -Dmaven.test.skip=true -T 1C

运行

编译完通过SeaTunnelEngineExample类来运行

SeaTunnel本地运行以及kafka发送到redis说明,大数据,kafka,redis,java

这样就运行成功啦

SeaTunnel本地运行以及kafka发送到redis说明,大数据,kafka,redis,java

附上配置文件样例

Kafka到Redis

env {
        execution.parallelism = 1
        job.mode = STREAMING
        checkpoint.interval = 20000
       }
source {
	   Kafka {
            bootstrap.servers = "xxx:9092,xxx:9092,xxx:9092"
            topic = "test_in"
            consumer.group = "1673212376113"
            format="json"
            result_table_name="kafka"
             schema = {
                fields {
                    cont = "STRING"
                }
            }
        }
}
sink {
    Redis {
        host = "xxx.xxx.x.xxx"
        port = "6379"
        key = "test_20230507"
        data_type = list
        auth = "xxx"
    }
}

Mysql到Redis

env {

  execution.parallelism = 2

  job.mode = "BATCH"

}

source {

  Jdbc {

      url = "jdbc:mysql://xxxxxx:3306/xxxxx"

      driver = "com.mysql.cj.jdbc.Driver"

      connection_check_timeout_sec = 100

      user = "root"

      password = "xxxxx"

      query = "select * from test"

      # partition_column = "id"

      # partition_num = 10

  }



}

sink {

Redis {

  host = xxxxxx

  port = 6379

  key = "seatunnel_jdbc"

  data_type = list

  auth = "xxxxxx"

}

}

运行结果
SeaTunnel本地运行以及kafka发送到redis说明,大数据,kafka,redis,java

常见问题

java.lang.RuntimeException: Plugin PluginIdentifier{engineType='seatunnel', pluginType='source', pluginName='XXXX'} not found.

SeaTunnel本地运行以及kafka发送到redis说明,大数据,kafka,redis,java

这种报错是seatunnel-engine-examples模块缺少引用，在pom中引用下对应插件重新编译即可

<dependency>
    <groupId>org.apache.seatunnel</groupId>
    <artifactId>connector-rabbitmq</artifactId>
    <version>${project.version}</version>
</dependency>

SeaTunnel本地运行以及kafka发送到redis说明,大数据,kafka,redis,java

mvn clean package -pl seatunnel-dist -am -Dmaven.test.skip=true

如果maven提示下载listenablefuture失败，可以通过连接下载

Could not find artifact com.google.guava:listenablefuture:jar:sources:9999.0-empty-to-avoid-conflict-with-guava文章来源地址https://www.toymoban.com/news/detail-553293.html

到了这里，关于SeaTunnel本地运行以及kafka发送到redis说明的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！