kafka工具

た入场券 2023-07-13 13:46 5阅读 0赞

/\*\*

*  kafka工具
 *  @author albert.ding  
    \*/  
    @Component  
    public class KafkaUtil \{
    
    @Autowired  
    private KafkaTemplate<String, byte\[\]> kafkaTemplate;
    
    /\*\*
    
     *  发送消息到kafka
     *  @author albert.ding
     *  @param topic
     *  @param key key值hash取模，根据模值决定写入哪个partition
     *  @param message  
        */  
        public void sendMsg(String topic, String key, byte\[\] message)\{  
        kafkaTemplate.send(topic, key, message);  
        \}  
        /*\*
     *  发送消息到kafka
     *  @author albert.ding
     *  @param topic
     *  @param key key值hash取模，根据模值决定写入哪个partition
     *  @param message  
        */  
        public void sendMsg(String topic, String key, String message)\{  
        try \{  
        sendMsg(topic, key, message.getBytes(Constant.DEFAULT\_CHARSET));  
        \} catch (UnsupportedEncodingException e) \{  
        \}  
        \}  
        /*\*
     *  发送消息到kafka
     *  @author albert.ding
     *  @param topic
     *  @param key key值hash取模，根据模值决定写入哪个partition
     *  @param message  
        \*/  
        public void sendMsg(String topic, String key, Object message)\{  
        String json = JSONObject.toJSONString(message);  
        try \{  
        sendMsg(topic, key, json.getBytes(Constant.DEFAULT\_CHARSET));  
        \} catch (UnsupportedEncodingException e) \{  
        \}  
        \}  
        \}

发表评论取消回复

表情：

评论列表（有 0 条评论，5人围观）

还没有评论，来说两句吧...

相关阅读

相关 Kafka——管理Kafka(命令行工具)详解

目录管理Kafka 1、主题操作（kafka-topic.sh） 1.1、创建主题(--create) 1.

小鱼儿/ 2023年10月14日 15:43/ 0 赞/ 73 阅读

相关 kafka工具

/\\ kafka工具 @author albert.ding \/ @Component public class Kafk

た入场券/ 2023年07月13日 13:46/ 0 赞/ 6 阅读

相关 kafka监控工具之kafka-manager的安装

一：kafka监控工具之kafka-manager的安装 1：kafka-manager的下载下载地址：[https://github.com/yahoo/kaf

一时失言乱红尘/ 2023年01月18日 06:50/ 0 赞/ 200 阅读

相关 Kafka工具类（Scala）

1、配置文件config.properties Kafka配置 kafka.broker.list = hadoop300:9092,hadoop301

川长思鸟来/ 2022年12月01日 15:47/ 0 赞/ 176 阅读

相关 Kafka工具--雅虎CMAK

原文网址：[Kafka工具--雅虎CMAK\_IT利刃出鞘的博客-CSDN博客][Kafka_--_CMAK_IT_-CSDN] 其他网址 > [kafka-manag

红太狼/ 2022年10月29日 15:29/ 0 赞/ 297 阅读

相关 Kafka工具--Kafka Tool

原文网址：[Kafka工具--Kafka Tool\_IT利刃出鞘的博客-CSDN博客][Kafka_--Kafka Tool_IT_-CSDN] 其他网址 [kafk

川长思鸟来/ 2022年10月29日 12:28/ 0 赞/ 411 阅读

相关 kafka 连接工具Kafka Tool 2.0.7

[Kafka Tool 2.0.7(最新)版本超详细使用指北][Kafka Tool 2.0.7] [Kafka Tool 2.0.7]: https://blog.csd

不念不忘少年蓝@/ 2022年10月21日 11:46/ 0 赞/ 407 阅读

相关 Kafka监控工具KafkaOffsetMonitor

Kafka监控工具KafkaOffsetMonitor 原文： http://blog.csdn.net/panguoyuan/article/details/4456

你的名字/ 2022年06月18日 03:15/ 0 赞/ 270 阅读

相关 Kafka监控工具

下载jar包地址 [https://pan.baidu.com/s/1ntzIUPN][https_pan.baidu.com_s_1ntzIUPN] 启用： jav

旧城等待，/ 2022年06月01日 23:35/ 0 赞/ 262 阅读

相关分布式日志传送工具kafka

要点： 1. 什么是kafka, 使用场景有哪些 2. kafka优缺点 3. 如何使用kafka（ shell接口， java api ） -----------

梦里梦外;/ 2022年05月15日 11:40/ 0 赞/ 219 阅读