jdbc-for-kafka:kafka的Java使用者API很乏味。 这是用于kafka的易于使用的JDBC

  • S7_759733
    了解作者
  • 55.3KB
    文件大小
  • zip
    文件格式
  • 0
    收藏次数
  • VIP专享
    资源类型
  • 0
    下载次数
  • 2022-05-29 06:16
    上传日期
卡夫卡 kafka的Java使用者API很乏味。 这是用于kafka的易于使用的JDBC。 相依性 该jdbc依赖于kafka中的SimpleConsumer。 因此,您必须将其与kafka_2.xx-0.xxxjar一起使用,请参阅要下载kafka,提取kafka,可以在libs子目录中找到jar-balls。 用法 您可以克隆此存储库,在根目录中有一个jdbc-for-kafka-xxxjar。 将这个jar文件和kafka jar文件添加到您的Java项目中。 这是示例测试代码: Class.forName("cn.edu.ruc.kafka.Driver"); Properties info = new Properties(); info.setProperty("role","consumer"); info.setProperty("clien
jdbc-for-kafka-master.zip
内容介绍
# jdbc-for-kafka The java consumer API of kafka is tedious. This is an easy-to-use JDBC for kafka. ## Dependency This jdbc relies on the SimpleConsumer in kafka. So you have to use it with kafka_2.xx-0.x.x.x.jar, see https://www.apache.org/dyn/closer.cgi?path=/kafka/0.8.2.1/kafka_2.10-0.8.2.1.tgz for downloading kafka, extract kafka, the jar-balls can be found in the libs sub directory. ## Usage You can clone this repo, there is a jdbc-for-kafka-x.x.x.jar in the root directory. add this jar file and the kafka jar file into your java project. Here is the example test code: > Class.forName("cn.edu.ruc.kafka.Driver"); Properties info = new Properties(); info.setProperty("role","consumer"); info.setProperty("client.id", "12345"); Connection conn = DriverManager.getConnection("kafka://log04:9092/test", info); Statement st = conn.createStatement(); ResultSet rs = st.executeQuery(Query.GET_LEADER_PARTITIONS_METADATA); while (rs.next()) { System.out.println(((Broker)rs.getObject("leader")).host() + ", " + rs.getInt("partitionId") + ", " + rs.getInt("sizeInBytes")); } st.close(); conn.close(); A full example of using jdbc-for-kafka can be found in src/cn/edu/ruc/kafka/test/KafkaJDBCTest
评论
    相关推荐
    • Kafka技术内幕
      Kafka技术内幕 Kafka技术内幕:图文详解Kafka源码设计与实现.郑奇煌
    • kafka elasticsearch
      通过获取kafka消息列队消费发送到elasticsearch做持久存储
    • chaperone:Kafka审核系统
      基本上,伴侣将时间线切成10分钟的存储桶,并根据其事件时间将消息分配给相应的存储桶。 存储桶的统计信息会相应更新,例如消息总数。 这些统计数据会定期发送给专门的Kafka主题,例如“陪伴审核”。 ...
    • Kafka管理工具Kafka Tool
      Kafka Tool是一个用于管理和使用Apache Kafka集群的GUI应用程序。它提供了一个直观的UI,允许用户快速查看Kafka群集中的对象以及存储在群集主题中的消息。
    • Kafka技术内幕
      本书以0.10版本的源码为基础,深入分析了Kafka的设计与实现,包括生产者和消费者的消息处理流程,新旧消费者不同的设计方式,存储层的实现,协调者和控制器如何确保Kafka集群的分布式和容错特性,两种同步集群工具...
    • kafka-playground
      卡夫卡游乐场 一个用于存放一些与Kafka相关的测试代码的运动场存储库。
    • Kafka_Learn.zip
      该代码包含kafka的生产者、消费者原理详解,各种参数解析,主题、分区、存储等的代码演示,可用于搭配博客学习
    • kafka-journal:使用Kafka作为主要存储的事件源日志实现
      kafka-journal:使用Kafka作为主要存储的事件源日志实现
    • zipkin-storage-kafka:基于Kafka的Zipkin存储
      邮编存储Kafka [EXPERIMENTAL] 基于Kafka的Zipkin存储。 +----------------------------*zipkin*---------------------------------------------- | [ dependency-storage ]--->( dependencies ) | ^ +--&...
    • kafka
      该项目需要将ojdbc jar文件添加到本地Maven存储库中 jar文件在仓库中可用 mvn install:安装文件-Dfile = ojdbc6.jar -DgroupId = com.oracle -DartifactId = ojdbc6 -Dversion = 12.1.0.2 -Dpackaging = jar