kafka 处理thrift序列化对象

java/python kafka thrift序列化

• • 一. 为什么使用thrift序列化？
  • • 1.1 理解跨语言

第二章 环境准备
* 2.1 配置kafka系统
* 2.2 构建Maven项目引入Kafka服务并集成Thrift协议库
* 2.3 Python开发环境配置完成流程如下：

* 三.thrift 结构体生成
* 四. 代码部分
* 可以用json不用thrift吗？

在学习Kafka的过程中往Kafka中发布数据时 我们发现大部分操作都是以字符串的形式进行的 并且这些操作通常使用Python脚本实现

程序将键序列化器设置为'org.apache.kafka.commonerialization.StringSerializer'；同时将值序列化器设置为"kafka.kafkaThriftSerierlize.serializer.ThriftSerializer"`。</

kafka系统实现了高效的流式处理能力，并支持自定义的序列化与反序列化功能。关于具体什么是序列化，请参考thrift序列化详细了解

一. 为什么使用thrift序列化？

1.thrift是跨语言的
2.体积小节省kafka空间

1.1 理解跨语言

现在我想将Java