kafka的数据存放,想做配置的修改

kafka的默认存放时间为7天,因为在做测试,所以想让他保留的时间长一点。修改了
log.retention.hours=1440
log.retention.bytes=1073741824
这个两个配置。但是今天在做测试的时候,发现kafka 的数据没有啦。只有四条数据啦。我就想知道kafka数据怎么就没有啦,是因为什么没有的。
望大神多多指教!

2个回答

修改完配置后,有没有重启一下kafka啊!

没有呀,我当时也是在csdn上边找的方法。

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
并行消费kafka存放本地文件
并行消费kafka存放本地文件
Kafka配置
URL:http://kafka.apache.org/downloads Version:kafka_2.10-0.8.2.1.tgzStep 1: 到上面的URL,下载指定的Kafka版本Step2: 在三个节点执行命令,建立特定的安装路径mkdir -p /opt/apps/kafka cd /opt/apps/kafka Step 3: 在node11中,使用xftp将下载的软
配置Kafka
1.最好是配置成三台,这里我只有2台机器(gk-1,gk-2),就这样配置了。 2.kafka各个节点配置 ,gk-1节点对应的机器 /etc/hosts如下: 3.  kafka配置文件,server.properties isteners=PLAINTEXT://:9092  zookeeper.connect=localhost:2181 broker.id=0  (其他kaf...
kafka配置
1.启动服务器 #启动zookeeper bin/zookeeper-server-start.sh config/zookeeper.properties #启动Kafka bin/kafka-server-start.sh config/server.properties 2.创建主题 #创建 bin/kafka-topics.sh --create --zookeeper localhost...
springboot配置kafka与原生kafka配置
搭建kafka要注意版本问题,本教程使用的kafka版本是kafka_2.11-0.11.0.2.tgz;首先看下spring-boot链接kafka的使用。       1. 添加pom依赖 org.springframework.boot spring-boot-starter-web 1.5.8.RELEASE--> org.apache.kafka kafka
配置kafka
broker 参数名称 默认值 说明 auto.create.topics.enable True broker.id 自动生成 delete.topic.enable False 如果为False则管理工具删除主题不会生效 log.retention.bytes -1 删除数据之前的最大大小 log...
KAFKA配置
[code="java"] 1、安装环境准备 1)系统:centos 6.5 64位,Ext4 2)安装包列表: Kafka:192.168.137.11/卷皮网/软件包目录/kafka/kafka_2.11-0.9.0.0.tar.gz zookeeper:软件件包和安装请看zk安装手册。 3)机器要求 ...
Docker | Docker调优 | 修改数据存放
                         --昨夜西风凋碧树,独上高楼,望尽天涯路 由于docker默认的数据存放目录/var/lib/docker/,文件空间很小,用一段时间就会满。所以需要修改docker的默认目录 1)首先通过df -h查看文件系统的使用和挂载情况 2)将docker的目录放置到/data目录下,进入data目录新建docker文件,并且通过cp -R将do...
Mysql 修改数据存放位置(windows)
导言mysql 可用于安装在linux系统,以及windows系统。默认情况下mysql 存放位置在安装时已经内置。位置查看本例中mysql 使用版本为 5.7,使用的工具navicat 版本为10.1.7 ,查看存储位置的操作为:1,在navicat 打开数据库,新建查询2,输入以下信息查询show global variables like "%datadir%";获取结果如下默认情况下,wi...
数据存放
struct sturnrn string m;rn string n;rn string p;rnrnrnstring str;rnrnwhile(getline(infile, str))rnrn 文件里面读到的数据 怎么才能把读到的数据依次存放结构的每个成员中rnrnrnC++
【kafka】kafka单节点安装及配置
前言 软件环境: 一台虚拟主机,配置IP为192.168.0.56。 软件依赖: 启用kafka自带的Zookeeper服务 Zookeeper是用java写的所以需要搭建JAVA环境(JDK版本 >= 1.7)。 1.安装JDK 目前官网不能直接下载,在网上找到1.8.0版本安装包下载到本地。 1.1.下载jdk #远程登陆主机 (使...
修改数据库的存放位置
网上搜了很多方法测试都不可以rn启动 mysql 都启动不了了。rnrn我想把 /var/lib/mysql 位置修改成 /home/datarnrn请问怎么做
18.配置flume收集数据kafka到hdfs
本章节为大数据架构师课程的综合案例课程,大数据生态体系庞大,通过本章节综合案例的讲授,你可以轻松的掌握综合案例技术,掌握本节内容后可以胜任企业级的开发,形成良好的大数据企业开发思维。 这套综合案例绝对三脚猫功夫,真正用心打磨出来,帮助更多的大数据技术爱好者少走弯路。n购买课程后加入qq群 831186576 (备注订单号后四位)
logstash将采取kafka的数据到elasticSearch配置
# 如下是logstash 将 kafka的数据到elasticSearch 的主要配置。 # 其中 consumer_threads 的配置跟kafka集群的分片和logstash的集群有很大关系 。 # kafka的每个分片只能给一个comsumer消费,consumer_threads如果大于kafka分片,将导致consumer_threads有些线程空闲;consumer_threa
修改Maven仓库的存放位置
Maven仓库类型 Local: 本地仓库 Remote: 远程仓库位置 Mirrors: 镜像仓库(e.g. Nexus, Artifactory) 修改步骤 在.m2目录下创建一个名为setting.xml的文件 在settings.xml中添加以下内容: <settings xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xs
kafka修改分区数量
./kafka-topics.sh –zookeeper localhost:2181 -alter –partitions 5 –topic userService
【kafka系列教程30】kafka修改删除topic
You can change the configuration or partitioning of a topic using the same topic tool. 你可以使用同样的topic工具更改topic的配置和分区。 To add partitions you can do 你可以添加分区 &gt; bin/kafka-topics.sh --zookeeper z...
【kafka系列教程28】kafka添加和修改topic
You have the option of either adding topics manually or having them be created automatically when data is first published to a non-existent topic. If topics are auto-created then you may want to tune ...
Kafka系列之-Kafka监控工具KafkaOffsetMonitor配置及使用
调用封装好的Producer,结合Kafka监控工具KafkaOffsetMonitor的使用与分析。
Kafka之——安装并(单节点)配置启动Kafka
1. 下载Kafka 从Kafka官网下载最新的Kafka,目前我下载的版本为kafka_2.10-0.8.1.1.tgz 2、解压Kafka tar -zxvf kafka_2.10-0.8.1.1.tgz 3. 修改Zookeeper服务器配置,并启动 cd kafka_2.10-0.8.1.1 vi config/zookeeper.properties #修改ZooKe
Kafka概念和关于springboot配置Kafka参数详解
1.基本概念 *Producer:            消息生产者,往Topic发布消息 *Consumer:            消息消费者,往Topic取消息并处理 *Consumer Group:            topic 可以广播给不同的group,一个group只能有一个consumer消费消息 *Broker(物理概念):            Kafka集...
kafka(三)—Kafka的Java代码示例和配置说明
本示以同步至个人博客liaosi's blog-Kafka的Java代码示例和配置说明,代码已上传至我的GitHub 配置类:Constants.java 消费者和生产者使用的几个常量。 package com.lzumetal.mq.kafka.demo; /** * &lt;p&gt;Description: &lt;/p&gt...
数据库存放图片:存放路径 or存放blob数据?
如题,通常,对图片,是把图片路径放到数据库呢,还是只存放图片路径?
kafka配置SSL(shell脚本)
kafka配置SSL的前几步骤,写成shell脚本了,方便!博客参考:https://blog.csdn.net/qq_34021712/article/details/79902479
Kafka在maven中的配置
http://mvnrepository.com/artifact/org.apache.kafka/kafka_2.12/1.1.1 &amp;amp;amp;lt;!-- https://mvnrepository.com/artifact/org.apache.kafka/kafka --&amp;amp;amp;gt; &amp;amp;amp;lt;dependency&amp;amp;amp;gt; &amp;amp;amp;lt;groupId&amp;amp;amp;gt;or
Kafka配置示例
一、kafka消息系统是一个高吞吐分布式高性能的消息系统,支持在线实时消息处理,他可持久化消息到本地磁盘(有生命周期)支持离线消息处理,随着集群负载的增加可横向扩展机器来实现集群扩容,通过zookeeper来实现负载均衡及broker的管理等等。 平台消息系统已上线,可支持大批量消息的传输,支持平台日志系统采集的各种日志的消息订阅,现有土豆实时计算,大屏幕,无线push等项目在使用。 ...
5.配置kafka环境
前提配置: 配置kafka需要先安装scala环境 1.安装scala 对scala-2.11.4.tgz进行解压缩:tar-zxvf scala-2.11.4.tgz 对scala目录进行重命名:mvscala-2.11.4 scala 配置scala相关的环境变量 vi .bashrc export SCALA_HOME=/usr/local/sc
kafka集群部署与配置手册
本文中包含了一套kafka集群的部署、配置、调试和压测的技术方法。 在三个主机节点上进行部署。 server1:192.168.10.1 server2:192.168.10.2 server3:192.168.10.3 1、jdk7u80的安装与配置 rpm -ivh jdk-7u80-linux-x64.rpm 配置环境变量: more /etc/p
mac下kafka安装及配置
》brew install kafka 4. 配置config/server.properties broker.id为依次增长的:0、1、2、3、4,集群中唯一id log.dirs设置到大硬盘路径下 num.network.threads num.partitions  ,默认分区数 num.io.threads 建议值为机器的核数; zookeeper.connect 设置
kafka配置以及安装
rm -f consumer.properties server.properties producer.properties zookeeper.properties  vi ./kafka/config/server.properties  :修改broker.id=1,host.name=kafka02 scp /etc/hosts storm03:/etc/ scp /etc/pro
kafka简单配置测试
下载kafka 下载地址:点击打开链接,不要下错了,src后缀的源码,我们需要的是另外一个,里面包含了kafka需要的.jar包,如果你对源码感兴趣可以下源码下来研究一下.  安装kafka  解压下载文件:tar xvf kafka_2.11-1.0.0.tar,进入解压目录cd kafka_2.11-1.0.0.tar  启动zookeeper    Kafka使用zookeeper
kafka 安装与配置
Kafka需要依赖JAVA环境运行,如何安装JDK这里不做介绍 下载 地址:https://kafka.apache.org/downloads 这里下载的是kafka_2.11-0.11.0.1.tgz wget http://mirror.bit.edu.cn/apache/kafka/1.1.0/kafka_2.11-1.1.0.tgz 解压 tar -xzf kafka_2.1...
kafka消息服务的producer、broker、consumer的配置
2019独角兽企业重金招聘Python工程师标准&gt;&gt;&gt; ...
kafka一份配置&说明
## 配置参考:https://blog.csdn.net/vegetable_bird_001/article/details/51858915 ## 官方说明:https://kafka.apache.org/documentation/ ## broker.id可以自动获取,但避免扩容、下线导致部分id出现重复,因此手工指定 broker.id=__BROKER_ID__ ## 是否通过管理...
Kafka安装与配置(单机)
test
Debezium:kafka 连接器配置
目的:构建基于hbase的实时数仓 解决的问题:RDBMS到Hbase的数据实时采集 方法:Postgresql    -----&amp;gt;     Debezium     -----&amp;gt;     Kafka     ------&amp;gt;     Sparkstreaming    ------&amp;gt;     Phoenix 本文:本文主要是kafka连接器一些相关配置 官网参考地址...
Kafka基础配置
Kafka是诞生于大数据时代伟大的消息组件,其大的特征是有着每秒百万级的数据处理能力,本课程将为读者讲解Kafka的工作原理、加密认证处理、SpringKafka操作等相关内容。
kafka详细配置
kafka详细配置
kafka安装与配置
kafka安装包
Kafka单机配置外网访问
问题:Kafka单机,broker内网地址192.168.1.100:9092,映射到外网XXXXXX:4006,springBoot install和运行失败,总是报连接broker超时 查了很多的帖子,总结加试验最后终于解决了,记录一下,希望给遇见同样问题的朋友一点帮助 1)放开advertised.listeners注释,配置为hostname:外网端口,注意:这里映射到外网的端口必...
相关热词 c++和c#哪个就业率高 c# 批量动态创建控件 c# 模块和程序集的区别 c# gmap 截图 c# 验证码图片生成类 c# 再次尝试 连接失败 c#开发编写规范 c# 压缩图片好麻烦 c#计算数组中的平均值 c#获取路由参数