Как использовать драйвер k sql -jdb c для доступа к kstream или ktable - PullRequest
Новая
       4

Как использовать драйвер k sql -jdb c для доступа к kstream или ktable

0 голосов
/ 10 марта 2020

Я сейчас пытаюсь использовать драйвер K SQL -JDB C для доступа к потоку K sql. Я застрял при использовании драйвера, Может кто-нибудь дать мне руку. Большое спасибо

import com.github.mmolimar.k sql .jdb c .KsqlConnection;

import com.github.mmolimar.k sql .jdb c. KsqlConnectionValues;

import com.github.mmolimar.k sql .jdb c .KsqlDriver;

import com.github.mmolimar.k sql .jdb c. KsqlStatement;

import scala .None;

import java. sql. *;

import java .util.Properties;

publi c class Main {

public static void main(String[] args) throws ClassNotFoundException, SQLException {

    Class.forName("com.github.mmolimar.ksql.jdbc.KsqlDriver");

    String url="jdbc:ksql://localhost:8089";

    KsqlDriver kd= new KsqlDriver();

    System.out.println(kd.acceptsURL(url));

    KsqlConnection con = kd.buildConnection(KsqlDriver.parseUrl(url), null);

    con.validate();

    Statement statement = con.createStatement();

    ResultSet rs = statement.executeQuery("select * from KSQLTEST");

      while(rs.next()){

      System.out.println(rs.getString(0)+" ： "+rs.getInt(1));

    }

}

}

...