go-kafka-example:Golang Kafka消费者和生产者示例

preview
共10个文件
go：2个
makefile：1个
gitignore：1个
golang
kafka
examples
stream-processing
star 5星 · 超过95%的资源 需积分: 31 8 下载量 39 浏览量 2021-05-06 05:28:19 上传 评论 收藏 196KB ZIP 举报
资源详情
资源评论
评论 收藏
BugHunter666
  • 粉丝: 22
  • 资源: 4699
上传资源 快速赚钱
voice
center-task 前往需求广场，查看用户热搜

相关推荐

zip

kafka-consumer-example

目录 kafka-consumer-example文件目录结构 src/main/java下包含两个工程。 一个是consumer_local,消费你的kafka topic中的消息，并写入指定的本地文件中。 一个是consumer_hdfs,消费你的kafka topic中的消息，并写入指定的HDFS文件中。 如何编译 如果已经安装了maven可使用git clone复制repo到本地之后，在E
zip

kafka-example:一个简单的Kafka消费者和生产者示例

简单的Kafka消费者-生产者示例 运行项目的步骤 下载Kafka 0.10.0.0二进制文件cd kafka_2.11-0.10.0.0 运行zookeeper和kafka服务器bin/zookeeper-server-start.sh config/zookeeper.properties bin/kafka-server-start.sh config/server.properties
zip

kafka-example:卡夫卡的例子

读我 kafka学习代码。 基础 代码： 消费者：com.example.kafka.consumer 生产者：com.example.kafka.producer 其中消费者均为单线程消费，分为手动提交、自动提交两个版本。 在生产下，肯定是多消费者（不管是多线程还是多进程）。 多线程 生产者 由于生产者是线程安全的，因此，更推荐一个生产者实例，多线程引用进行生产的方式。这种方式通常要比每个线程维
pdf

golang kafka sarama 消费者组

之前用kafka，没在网上找到关于 sarama消费者组的代码。后来才在源码里面找到例子，现在稍微修改了下代码，记录一下。 package main import ( context github.com/Shopify/sarama log github.com/sirupsen/logrus os os/signal sync syscall time ) type Kafk
star 5星 · 资源好评率100%
pdf

Go操作kafka—-kafka简介

一.kafka简介 1.介绍 kafka是一个分步数据流平台，可以分布在单个服务器上，也可以分布在多个服务器上部署形成集群，提供了发布和订阅功能，使用者可以发送数据到kafka中，也可以从kafka中读出数据，kafka具有高吞吐，低延迟，高容错等特点。 2.kafka集群的架构 代理（Broker）:缓存代理，Kafka的核心功能 生产者（Producer）:消息和数据生产者 消费者（Cons
zip

Go-Golang程序从一组kafka主题中读取记录并将它们写入elasticsearch集群

Golang程序从一组kafka主题中读取记录并将它们写入elasticsearch集群
zip

example-consumer-golang：使用Golang的示例消费者

消费者示例 （最新条约） （产品/产品契约） 这是Golang消费者使用Pact创建消费者驱动的合同并通过共享合同的。 它正在Pactflow上使用公共租户，您可以使用凭证dXfltyFMgNOFZAxr8io9wJ37iUpY42M / O5AIZWxelWbLvqMd8PkAVycBJh2Psyg1 。 示例消费者/示例提供者协议的最新版本在发布。 该项目使用Makefile来模拟一
zip

kafka-nodejs-example：使用Kafka和NodeJS中的生产者和消费者的展示

Kafka NodeJS示例 介绍 该存储库展示了将Kafka与NodeJS结合使用的示例。 在此示例中，我们将Kafka用作消息传递系统，以将假设的销售量插入数据库中。 它不是将我们的销售端点直接打入数据库，而是将销售数据推送到Kafka，从而充当“生产者”。 我们启动了一个“消费者”，它将从Kafka中获取数据并将其推入数据库。 使用说明 本演示假定您已经安装了docker和docker-c
zip

kafka-consumer:Kafka消费者示例

卡夫卡消费者 Kafka消费者示例
pdf

kafka生产者和消费者的javaAPI的示例代码

主要介绍了kafka生产者和消费者的javaAPI的示例代码，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
star 5星 · 资源好评率100%
zip

confluent-kafka-go-producer-example：基于Confluent的Kafka Go库的Kafka生产者示例

概述 本存储库包含Kafka生产者的示例性实现。 该实现基于Confluent Kafka Go库和Confluent的示例实现的略微扩展，可以在找到。 用法 要构建Kafka生产者，只需执行以下命令： $ make 确保之前已安装。 可以使用以下命令运行示例应用程序： confluent-kafka-go-producer-example-amd64 -c config.yaml proc
zip

flink-connector-kafka-0.10-2.11-1.10.0-API文档-中文版.zip

赠送jar包：flink-connector-kafka-0.10_2.11-1.10.0.jar； 赠送原API文档：flink-connector-kafka-0.10_2.11-1.10.0-javadoc.jar； 赠送源代码：flink-connector-kafka-0.10_2.11-1.10.0-sources.jar； 赠送Maven...
star 5星 · 资源好评率100%
zip

flink-connector-kafka-2.12-1.14.3-API文档-中文版.zip

赠送jar包：flink-connector-kafka_2.12-1.14.3.jar 赠送原API文档：flink-connector-kafka_2.12-1.14.3-javadoc.jar 赠送源代码：flink-connector-kafka_2.12-1.14.3-sources.jar 包含翻译后的API文档：flink-...
star 5星 · 资源好评率100%
jar

kafka-schema-registry-client-6.2.2.jar

mvn install:install-file -DgroupId=io.confluent -DartifactId=kafka-schema-registry-client -Dversion=6.2.2 -Dfile=/root/kafka-schema-registry-client-6.2.2.jar -Dpackaging=jar 官网下载地址 packages....
zip

flink-connector-kafka-base-2.11-1.10.0-API文档-中文版.zip

赠送jar包：flink-connector-kafka-base_2.11-1.10.0.jar； 赠送原API文档：flink-connector-kafka-base_2.11-1.10.0-javadoc.jar； 赠送源代码：flink-connector-kafka-base_2.11-1.10.0-sources.jar； 赠送Maven...
star 5星 · 资源好评率100%
zip

Kafka-Simple-Producer-Consumer:使用Java 8的kafka的生产者和消费者的简单变化

Kafka-Simple-Producer-Consumer:使用Java 8的kafka的生产者和消费者的简单变化
zip

example-consumer-java-kafka:示例Java Kafka使用者

示例Java Kafka使用者 这是一个Java kafka使用者的示例，该使用者使用Pact， 和Travis CI来确保其与其使用者所期望的兼容。 该项目使用Makefile来模拟一个非常简单的构建管道，分为两个阶段-测试和部署。 请参阅此处的规范消费者示例： : 另请参见完整的 ，可以将其替换为“消费者”。 在下图中，我们将测试“产品API”，这是一个简单的HTTP服务，它以RES
zip

go-amqp-example:Golang中RabbitMQ消息的生产者和消费者示例

go-amqp-example Golang中RabbitMQ消息的发布者和消费者示例 要求 以下说明假设您已正确安装Go （并且正确设置了 $GOPATH）并使用默认设置安装了RabbitMQ 。 获取代码 go get github.com/andreagrandi/go-amqp-example 代码将在$GOPATH/src/github.com/andreagrandi/go-amq
zip

fsharp-kafka-simple:F＃中Kafka生产者和消费者的简单实现

fsharp-kafka-简单 F＃中Kafka生产者和消费者的简单实现 执行以下操作以在Docker中构建它： git clone https://github.com/anaerobic/fsharp-kafka-simple.git cd fsharp-kafka-simple sudo sh docker-build.sh 使用以下命令启动Kafka： docker run -d -
zip

kafka-apm-example:Kafka 的 APM 示例

kafka-apm-example Kafka 的 APM 示例 收集的架构 跟踪由发送到。 收集器在名为otlp_spans的 Kafka 主题中发送跟踪。 您可以通过 AKHQ 在看到这个主题。 然后第二个 OpenTelemetry 收集器使用来自 Kafka 的跟踪并将它们发送到两个不同的工具中。 一种是 。 您可以在 另一个是。 您可以在找到结果。 使用简单的 kafka 生产者
zip

flink-connector-kafka-2.12-1.14.3-API文档-中英对照版.zip

赠送jar包：flink-connector-kafka_2.12-1.14.3.jar； 赠送原API文档：flink-connector-kafka_2.12-1.14.3-javadoc.jar； 赠送源代码：flink-connector-kafka_2.12-1.14.3-sources.jar； 赠送Maven依赖信息文件：...
star 5星 · 资源好评率100%
zip

spring-boot-starter-kafka示例程序

spring-boot-starter-kafka示例程序\n 支持springcloud1.5.4，kafka0.8.2.x\n 项目地址：https://github.com/zhyea/spring-boot-starter-kafka
zip

flink-connector-kafka_2.11-1.7.1-API文档-中英对照版.zip

赠送jar包：flink-connector-kafka_2.11-1.7.1.jar； 赠送原API文档：flink-connector-kafka_2.11-1.7.1-javadoc.jar； 赠送源代码：flink-connector-kafka_2.11-1.7.1-sources.jar； 赠送Maven依赖信息文件：flink-...
jar

flink-sql-connector-kafka_2.11-1.12.0.jar

flink-sql-connector-kafka_2.11-1.12.0
zip

spring-boot-kafka-consumer-example:Spring Boot Kafka使用者示例

带有Kafka Consumer实例的Spring Boot ...bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic Kafka_Example bin/kafka-topics.sh --create --zookeeper loc
zip

mapr-kafka-avro:弹性地图Kafka Micro服务（生产者和消费者）

使用Spring Cloud Stream + Avro + MapR Kafka进行架构演化 服务/生产者/消费者模式的发展始终具有挑战性。 作为一名架构师/开发人员，我想设计自己的服务/生产者/消费者以适应不同的有效负载方案。 在大数据世界中，这个问题变得越来越严重。 让我们进一步探讨这个问题。 MapR为构建Data Lake提供了强大的支持。 建立数据湖的基石之一是“数据摄取”。 数据工
zip

kafka-service-interface:公开Kafka生产者和消费者API的Docker服务

kafka服务接口 公开Kafka生产者和消费者API的Docker服务 该服务提供了一种简单的方法，可以将Kafka生产者和使用者API添加到您的应用程序中。 该Kafka服务与其他docker compose服务之间的通信是通过http回调完成的。 官方支持的Kafka客户端库使用Java。 已经编写了其他语言的客户端库，但是其中一些错误和过时。 这种方法使您可以轻松地将Kafka集成到任何
zip

example-netty-kafka:Apache Kafka 的示例 Http (Netty) 生产者

启动动物园管理员 ./bin/zookeeper-server-start.sh config/zookeeper.properties 启动卡夫卡 ./bin/kafka-server-start.sh config/server.properties 创建主题 ./bin/kafka-topics.sh --create --zookeeper localhost:2181 --repl
zip

go-microservices-example:用Golang编写的微服务示例

#Go Microservices示例用Golang编写的一些微服务的容器。 这是2015年8月11日在Golang Vietnam的聚会上演讲的示例项目。 更多信息即将推出。