宁静致远

0 声望

这家伙太懒，什么都没留下

个人动态
  • 半兽人 回复 宁静致远 在 Kafka Producer配置 中 ：

    哈哈，恭喜。

    5年前
  • 宁静致远 回复 半兽人 在 Kafka Producer配置 中 ：

    就在刚刚，终于知道是怎么回事了，哈哈哈哈哈哈哈，好开心。正确的配置确实是kafkaParameters.put("fetch.message.max.bytes","52428800")，因为刚开始我可能给设置成5242880000，超过了int的大小（估计这个值应该是int，不应该是Long）,int的取值范围是（-2147483648~2147483648）；而后来又给设置成52428800L（Long）了，所以也是转化的过程中报错了，所以最后配置成52428800就成功了。哈哈哈  谢谢大神的引导~~~~

    5年前
  • 半兽人 回复 宁静致远 在 Kafka Producer配置 中 ：

    java写的用这个呀。

    Properties props = new Properties();

    5年前
  • 宁静致远 回复 無名 在 Kafka Producer配置 中 ：

    是scala写的  提供的有scala API，也有java API，我使用java写的~

    5年前
  • 無名 回复 宁静致远 在 Kafka Producer配置 中 ：

    spark streaming是scala写的吧，理论上用的也是java的客户端。

    5年前
  • 订阅了 kafka 主题！ · 5年前
  • 关注了用户 半兽人 · 5年前