标签: Kafka

<dependencies>
    <dependency>
        <groupId>org.apache.kafka</groupId>
        <artifactId>kafka-clients</artifactId>
        <version>3.7.1</version>
    </dependency>
    <dependency>
        <groupId>org.slf4j</groupId>
        <artifactId>slf4j-api</artifactId>
        <version>2.0.13</version>
    </dependency>
    <dependency>
        <groupId>org.slf4j</groupId>
        <artifactId>slf4j-log4j12</artifactId>
        <version>2.0.13</version>
    </dependency>
</dependencies>

添码座原创大约 2 分钟

Kafka高级特性

可以通过Kafka的配置文件server.properties来扩展它更多的高级功能。

Broker

server.properties中配置Broker的完整参数说明。

添码座原创大约 6 分钟

一个简单的聊天群

先创建一个名为qq的Topic。

> ./bin/kafka-topics.sh --create --bootstrap-server 172.16.185.176:9092 --replication-factor 1 --partitions 2 --topic qq
Created topic qq.

添码座原创小于 1 分钟

什么是Kafka？

什么是Kafka

Kafka和RocketMQ一样，也是一个分布式的消息队列系统，但它和RocketMQ的一个显著区别在于其超高吞吐量，这也是它最大的特色。

添码座原创大约 4 分钟

从Kafka到RocketMQ

如果之前使用的是Kafka，但现在想将系统迁移到RocketMQ上去的话，是不可能一下子将所有Kafka服务器全部停掉，然后将业务数据直接写入到RocketMQ的，这需要有一个循序渐进的过程，主要是分三步走。

添码座原创大约 2 分钟