标签：集成 springcloudStream group consu destination testquickstart kafka echo Kafka

最近做kafka存储文件类型的信息的项目，遇到两个问题一个是springcloudstream的版本问题，这个问题只需要注意在引入maven依赖的时候不添加version就可以避免，把版本管理问题交给

springcloud来管理，比如我用的是--<spring.cloud.version>Hoxton.SR12</spring.cloud.version>

<spring.cloud.alibaba.version>2.2.7.RELEASE</spring.cloud.alibaba.version>。

<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-stream-binder-kafka</artifactId>
</dependency>

引入依赖之后就需要配置配置文件：

spring.cloud==这里省去上两层
stream:
      kafka:
        binder:
          producerProperties:
            max:
              request:
                size: 209715200 
          brokers: 127.0.0.1:9092
          auto-create-topics: true
      bindings:
        input-in-0:
          destination: testquickstart
          group: myinput1
        output:
          destination: testquickstart
        consu-in-0:
          destination: testquickstart2
          group: consu
        echo-in-0:
          destination: testquickstart
          group: echo
        echo-out-0:
          destination: testquickstart2
      function:
        definition: echo;input;consu

这里遇到一个

---大文件报错：
org.apache.kafka.common.errors.RecordTooLargeException: The message is 17108616 bytes when serialized which is larger than 1048576, which is the value of the max.request.size configuration.

实际就是添加上下面的配置就可以了。

producerProperties:
            max:
              request:
                size: 209715200 

在kafka中存放文件类型的消息，是将文件二进制流进行base64编码，来传送的。

参见spring官网。

标签：集成,springcloudStream,group,consu,destination,testquickstart,kafka,echo,Kafka
来源： https://www.cnblogs.com/zhangdanyang95/p/16378619.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。