首页 > TAG信息列表 > TOPICNAME
kafka问题排查
一、找到部署机器ip 二、排查问题 1、测试环境不能用topic能用,tcp报错如下图 (1)验证kafka是否可用 开启一个生产者和消费者查看kafka是否正常,如下 路径:cd /usr/local/kafka/1/bin 生产者:sh kafka-console-producer.sh --broker-list 10.30.200.155:15386 --topic CAR_NEkafka消费数据命令 消费以前的数据命令
到kafka 的bin目录下 [root@node2 bin]# ./kafka-console-consumer.sh --bootstrap-server ip:9092 --topic topicname 消费以前的数据 [root@node2 bin]# ./kafka-console-consumer.sh --bootstrap-server ip:9092 -- --from-beginning topic topicname修改kafka中某一主题的数据存留时间
我们都知道,kafka中默认消息的保留时间是7天,若想更改,需在配置文件 server.properties里更改选项: log.retention.hours=168 但是有的时候我们需要对某一个主题的消息存留的时间进行变更,而不影响其他主题。且kafka集群不用重启 可以使用命令: ./kafka-configs.sh --zookeeper lokafka工具类
背景 在做数据开发时,经常预见要查看kafka 元数据的一些信息,比如有多少个topic、某个topic中有多少分区、创建topic、删除topic等等。 代码 废话不多,直接撸。 我们的maven版本为: <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.13</artiJS设计模式入门和框架中的实践
JS设计模式入门和框架中的实践 在编写JS代码的过程中,运用一定的设计模式可以让我们的代码更加优雅、灵活。 下面笔者就结合诸如redux的subscribe、ES6的class、vue里面的$dispatch、jquery里面的on/off来给大家简单介绍下设计模式在这些库、语法和框架中的使用。 设计模式解决删除kafka数据(docker安装)
1.删除topic ①进入kafka容器 docker exec -it kfk bash ②使用客户端连接zookeeper cd /opt/zookeeper/bin/ ./zkCli.sh -server ip:2181 #此处写kafka地址,端口默认2181 执行删除命令 rmr /brokers/topics/topicname #topicname为要删除的topic rmr /brokers/topics/__conzabbix LLD 自定义脚本
一 前言 每次写技术文档,都想发表一下现在的情绪,真的很久很久,没写文档了。可能是自己变懒了,又或者真的没啥心情写了吧。最近一年改变很多,该走的人拦不住,该来的人你也挡不住,还是顺其自然吧,经过一年的时间也慢慢学会了自己独处。 有时想想人孤零零的一个人来着世上,不管中间经过多少人,