Shell 直接向kafka 的Topic发送消息

猫咪的一生

2020-06-03

关注关注

1.常见的我们是进入它的消费者模式 , 在里面输入 , 但是如何封装到shell中

kafka-console-producer.sh --broker-list node1:9092 --topic sky

比如我只想把 hello 这条消息发送到Topic sky里面

echo "hello" | kafka-console-producer.sh --broker-list node1:9092 --sync --topic sky

这样就是把显示hello作为源发送到Topic

如果想发送文本

cat 文件 | kafka-console-producer.sh --broker-list node1:9092 --sync --topic sky

也会一行一行发送.

topic shell kafka 科技新闻

猫咪的一生

0 关注 0 粉丝 0 动态

关注关注

RabbitMQ都写了，RocketMQ怎么能落下？

整体架构最近看到了我在Github上写的rabbitmq-examples陆续被人star了，就想着写个rocketmq-examples。对rabbitmq感兴趣的小伙伴可以看我之前的文章。下面把RocketMQ的各个特性简单介绍一下，这样在用的时候心里

ljcsdn 2020-07-27

Rabbitmq的使用四_Java Client方式使用Topic模式

topic交换机发送给队列的消息，通过routingkey进行匹配。　　* 号只能代替一个单词。　　# 号可以替换零个或多个单词。在这个例子中，我们将发送所有描述动物的信息。消息将与一个routingkey一起发送，routingkey由三个单词(两个点)

woaishanguosha 2020-07-18

RocketMQ系列（三）消息的生产与消费

前面的章节，我们已经把RocketMQ的环境搭建起来了，是一个两主两从的异步集群。接下来，我们就看看怎么去使用RocketMQ，在使用之前，先要在NameServer中创建Topic，我们知道RocketMQ是基于Topic的消息队列，在生产者发送消息的时

qingyuerji 2020-06-14

RocketMQ系列（四）顺序消费

折腾了好长时间才写这篇文章，顺序消费，看上去挺好理解的，就是消费的时候按照队列中的顺序一个一个消费；而并发消费，则是消费者同时从队列中取消息，同时消费，没有先后顺序。RocketMQ也有这两种方式的实现，但是在实践的过程中，就是不能顺序消费，好不容易能够实

MojitoBlogs 2020-06-14

ActiveMQ

--消息队列连接池-->

xinglun 2020-06-14

RocketMQ系列（三）消息的生产与消费

MojitoBlogs 2020-06-09

kafka消息队列

Kafka适合离线和在线的消息消费,其消息保存在磁盘上。Kafka以Topic为单位进行消息的归纳,Producers向Topic发送消息,Consumers会消费预订了Topic的消息。多个Broker可以做成一个Cluster(集群)对外提供服务,每个

guicaizhou 2020-05-05

Kafka核心技术与实战——08 | 最最最重要的集群参数配置（下）

答案就是 Topic 级别参数会覆盖全局 Broker 参数的值，而每个 Topic 都能设置自己的参数值，这就是所谓的 Topic 级别参数。retention.ms：规定了该 Topic 消息被保存的时长。retention.bytes：规定了要为该

猫咪的一生 2020-05-03

kafka基本命令和实践

./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 -partitions 1 --topic test

jiangkai00 2020-04-15

activeMQ中queue 与 topic 区别

3.queue模式生产者与消费者之间没有时间相关性，topic模式下生产者和消费者之间有一定的时间相关性，消费者只能接收到订阅之后的生产者发送的消息。

方新德 2020-04-08

kafka基础命令

　　消息生产者，发布消息到 kafka 集群的终端或服务。　　每条发布到 kafka 集群的消息属于的类别，即 kafka 是面向 topic 的。　　partition 是物理上的概念，每个 topic 包含一个或多个 partition。kafka 分

jiangkai00 2020-03-20

kafka术语

kafka broker：运行kafka server的服务被称为broker,它主要用于接手topic消息，管理topic,持久化和存储topic数据，kafka审计，kafka权限管理等。；kafka仅支持topic模式。topic partition

那年夏天0 2020-02-22

Kafka Topic Partition GroupId 及高可用

Topic主题用来区分不同类型的消息，实际也就是适用于不同的业务场景，默认消息保存一周时间；同一个Topic主题下，默认是一个partition分区，也就是只能有一个消费者来消费，如果想提升消费能力，就需要增加分区；消费者消费partition分区内的消息

sweetgirl0 2020-02-21

Kafka常用topic操作命令汇总

bin/kafka-topics.sh --create --zookeeper localhost:2181 --topic test_topic --replication-factor 3 --partitions 10 --config clean

sweetgirl0 2020-02-09

【kafka】常用命令行

topic的分区会被创建在当前主机，每个分区的副本会分配到集群的其他机器；# --zookeeper master:2181；信息写入zookeeper. $ kafka-topics.sh --create --zookeeper master:2181

MrZhangAdd 2020-01-13

jiangkai00 2020-01-12

golang nsq 同一个topic有多个channel,同时项目又互相引用事出现的问题

同一个topic下不同channel分多个项目的时候,如果一个项目引用了别的项目包,那么被引用的项目就需要手动初始化mq,不能使用Init,因为会导致mq初始化两次,在一个channel下链接了两个消费者导致mq进行了负载均衡.

GoatSucker 2020-01-11

认识kafka

kafka是一个高吞吐量,低延迟分布式的消息队列系统.kafka每秒可以处理几十万条消息,它的延迟最低只有几毫秒。kafka将所有消息组织成多个topic的形式存储,而每个topic又可以拆分成多个partition,每个partition又由一个一个消息

yangyutong00 2019-12-30

kafka（一）

//创建一个topic,名称为test_kafka，partitions为2个，replication有3个，topic的name为test2:. kafka-topics --zookeeper zk1:2181,zk2:2181,zk3:2181 --

amwayy 2019-12-22

Kafka的安装与使用(转)

点对点消息系统：生产者发送一条消息到queue，一个queue可以有很多消费者，但是一个消息只能被一个消费者接受，当没有消费者可用时，这个消息会被保存直到有一个可用的消费者，所以Queue实现了一个可靠的负载均衡。发布订阅消息系统：发布者发送到topic

amwayy 2019-12-21

安科网

Shell 直接向kafka 的Topic发送消息

猫咪的一生

猫咪的一生

相关推荐

RabbitMQ都写了，RocketMQ怎么能落下？

Rabbitmq的使用四_Java Client方式使用Topic模式

RocketMQ系列（三）消息的生产与消费

RocketMQ系列（四）顺序消费

ActiveMQ

RocketMQ系列（三）消息的生产与消费

kafka消息队列

Kafka核心技术与实战——08 | 最最最重要的集群参数配置（下）

kafka基本命令和实践

activeMQ中queue 与 topic 区别

kafka基础命令

kafka术语

Kafka Topic Partition GroupId 及高可用

Kafka常用topic操作命令汇总

【kafka】常用命令行

kafka的相关操作脚本

golang nsq 同一个topic有多个channel,同时项目又互相引用事出现的问题

认识kafka

kafka（一）

Kafka的安装与使用(转)

猫咪的一生