之前的样例中消费者这边都直接获取消息内容并使用，如果我们还想要获取分区信息、消息头等其他内容的话，有如下两种方式。 七、消费者2：获取消息头和消息体 1，使用 ConsumerRecord 类方式 （1）使用 ConsumerRecord 类接收有一定的好处......
六、消费者1：指定 topic、partition、offset 1，使用 topics 指定 topic （1）监听器主要是使用 @KafkaListenter 注解即可，而通过 topics 参数设置监听的 topic（可监听多个，用逗号隔开）： 其他参数介绍：id（消费者 ID）、 groupId（消费组 ID......
Kafka 同数据库一样支持事务，当发生异常或者出现特定逻辑判断的时候可以进行回滚，确保消息监听器不会接收到一些错误的或者不需要的消息。Kafka 使用事务有两种方式，下面分别进行介绍。 五、生产者3：使用事务 1，使用 executeInTransaction 方法......
当我们发送消息到 Kafka 后，有时我们需要确认消息是否发送成功，如果消息发送失败，就要重新发送或者执行对应的业务逻辑。下面分别演示如何在异步或者同步发送消息时，获取发送结果。 四、生产者2：消息回调、同步异步发送消息 1，获取异步发送消息的结果......
三、生产者1：指定 topic、partition、key 等 1，send() 方法 （1）在之前的文章中我们都是通过 KafkaTemplate 的 send() 方法指定一个 topic 发送消息，其实 send() 方法还支持其他参数，具体如下： 参数说明： topic：这里填写的是 Topic 的名字 partition......
在之前的文章样例中，我们发送消息的时候并没有事先创建相应的 Topic。这是因为 KafkaTemplate 在发送的时候就已经帮我们完成了创建的操作。 但这样也会存在一些问题，比如这种情况创建出来的 Topic 的 Partition（分区)）数永远只有 1 个，也不会有副本......
Kafka 是一个由 LinkedIn 开发的分布式消息系统，详细介绍可以查看我之前的文章。本文演示如何在 Spring Boot 项目中集成并使用 Kafka。 一、安装配置 1，环境准备 关于 Kafka 和 ZooKeeper 的安装，可以参考我之前写的文章： 2，项目配置......
Kafka Tool 2 是一款 Kafka 的可视化客户端工具，可以非常方便的查看 Topic 的队列信息、消费者信息以及 kafka 节点信息。下面介绍如何使用这个工具。 1，下载安装 这款软件支持在 Windows、Mac 和 Linux 上面运行，我们到其官网选择合适的版本下载安装即可......
有时我们需要对现有的项目进行改名，或者从模版项复制一份出来然后改名作为新项目，只需要如下几个步骤（开发工具以 Intellij IDEA 为例）： 1，修改项目名 （1）假设我们项目为 hangge，需要修改成 test，首先直接将项目文件夹名称修改成 test......
telnet ip 端 由于公司服务器使用的是内网，无法通过 yum install telnet-server 命令直接在线安装 telnet。下面演示何如通过下载离线包，手动进行安装（这里以 CentOS 7 系统为例）。 1，离线包下载 （1）首先下载 telnet-client (或 telnet) 客户端软件包......