发送自定义数据/对象请查看：发送自定义数据/自定义对象一，生产者的的使用：package com.kuxingseng.lbw.mq;import com.fasterxml.jackson.core.JsonProcessingException;import com.fasterxml.jackson.databind.ObjectMapper;import org.apache.kafka.

vue+element 组件。<template><div><el-uploadclass="upload-demo"multipleaction="api":on-preview="handlePreview":on-remove="handleRemove":file-list="fileList":http-request="httpRequest"..

前提：需要实现kafka生产者，如果没有实现，请查看我的这篇kafka生产者的使用https://blog.csdn.net/LB3701/article/details/106933936**kafka(卡夫卡消费者)的使用。**一，创建消费者MyConsumer.java。package com.kuxingseng.lbw.mq;import org.apache.kafka.clients

kafka(卡夫卡消费者)的使用。一，创建消费者 MyProducer.java 。package com.kuxingseng.lbw.mq;import org.apache.kafka.clients.producer.*;import org.apache.kafka.common.KafkaException;import org.apache.kafka.common.errors.R

系统：Ubuntu 14环境： jdk1.8 【为后面的安装kafka准备 这里使用jdk8】可以从 https://zookeeper.apache.org/releases.html 下载ZooKeeper，3.4.14版本，用户可以自行选择一个速度较快的镜像来下载即可。上传下载好的文件zookeeper-3.4.14.tar.gz解压：tar -zxvf zookeeper-3.4.14.t

发送自定义数据/对象请查看：发送自定义数据/自定义对象一，生产者的的使用：package com.kuxingseng.lbw.mq;import com.fasterxml.jackson.core.JsonProcessingException;import com.fasterxml.jackson.databind.ObjectMapper;import org.apache.kafka.