首页 > 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 自定义脚本

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