kafka怎么查看topic
阴曼彩681怎么彻底删除kafka的topic,然后重建 -
寇齿纨17394599158 ______ 1、从zookeerer删除信息./bin/kafka-run-class.sh kafka.admin.DeleteTopicCommand --zookeeper 10.0.1.10:2181,10.0.1.11:2181,10.0.1.12:2181 --topic test成功后返回信息:deletion succeeded!2、利用JPS命令查看kafka和zookeeper进程,kill掉...
阴曼彩681如何删除kafka积压数据 -
寇齿纨17394599158 ______ Kafka删除数据有两种方式按照时间,超过一段时间后删除过期消息按照消息大小,消息数量超过一定大小后删除最旧的数据 Kafka删除数据的最小单位:segment Kafka删除数据主逻辑:kafka源码 def cleanupLogs() { debug(＂Beginning log ...
阴曼彩681spark接kafka怎么区分topic -
寇齿纨17394599158 ______ 收到的数据是(key, value)格式,key是kafka message的topic, value是message的payload
阴曼彩681如何在Kafka中对Topic的leader进行均衡 -
寇齿纨17394599158 ______ 在创建一个topic时,kafka尽量将partition均分在所有的brokers上,并且将replicas也j均分在不同的broker上. 每个partitiion的所有replicas叫做＂assigned replicas＂,＂assigned replicas＂中的第一个replicas叫＂preferred replica＂,刚...
阴曼彩681请教java向kafka发消息 -
寇齿纨17394599158 ______ 这是我们项目中用到的代码 public class ProducerService { private static Logger log = Logger.getLogger(ProducerService.class); private static Producer producer = null; private static String serviceIp = PropertiesUtils.getValue(＂/epoo.properties＂,...
阴曼彩681linux怎样使用top命令查看系统状态 -
寇齿纨17394599158 ______ top命令说明 top命令可以实时动态地查看系统的整体运行情况,是一个综合了多方信息监测系统性能和运行信息的实用工具.通过top命令所提供的互动式界面,用热键可以管理.语法 top(选项) 选项-b:以批处理模式操作;-c:显示完整的治...
阴曼彩681kafka 怎么创建group -
寇齿纨17394599158 ______ innodb_log_file_size = 500M #事物日志大小 #innodb_log_file_size =100M innodb_log_files_in_group = 2 #两组事物日志 innodb_log_group_home_dir = /longxibendi/mysql/mysql/var/#日志组
阴曼彩681kafka offset是否有序 -
寇齿纨17394599158 ______ massage: kafka中最基本的传递对象,有固定格式.topic: 一类消息,如page view,click行为等.producer: 产生信息的主体,可以是服务器日志信息等.consumer: 消费producer产生话题消息的主体.broker: 消息处理结点,多个broker组成kafka集群.partition: topic的物理分组,每个partition都是一个有序队列.segment: 多个大小相等的段组成了一个partition.
阴曼彩681kafka消费者java版本读取不到消息怎么办 -
寇齿纨17394599158 ______ 是不是linux上配置的zookeeper和kafka地址写成127.0.0.1了.要配置成对外的IP才可以收到消息的.
阴曼彩681java kafka 怎么传输对象 -
寇齿纨17394599158 ______ 1.zookeeper集群 搭建在110, 111,112 2.kafka使用3个节点110, 111,112 修改配置文件config/server.properties broker.id=110 host.name=192.168.1.110 log.dirs=/usr/local/kafka_2.10-0.8.2.0/logs 复制到其他两个节点,然后修改对应节点上的config...