首页 > 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_NE

kafka消费数据命令 消费以前的数据命令

到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 lo

kafka工具类

背景 在做数据开发时,经常预见要查看kafka 元数据的一些信息,比如有多少个topic、某个topic中有多少分区、创建topic、删除topic等等。 代码 废话不多,直接撸。 我们的maven版本为: <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.13</arti

JS设计模式入门和框架中的实践

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/__con

zabbix LLD 自定义脚本

一 前言 每次写技术文档,都想发表一下现在的情绪,真的很久很久,没写文档了。可能是自己变懒了,又或者真的没啥心情写了吧。最近一年改变很多,该走的人拦不住,该来的人你也挡不住,还是顺其自然吧,经过一年的时间也慢慢学会了自己独处。 有时想想人孤零零的一个人来着世上,不管中间经过多少人,