全部博文
-
编辑 删除
Kakfa异常CommitFailedException
Kafka消费者遇到的异常
-
编辑 删除
Spark streaming 集成kafka Kerberos
kafka安全特性可在0.9版本之后开启 https://www.cloudera.com/documentation/enterprise/release- notes/topics/cdh_rn_spark_ki.html#ki_spark_streaming_consumer_api spark版本需要在2.1以上支持kafka的安全特性 参照链接：...
-
编辑 删除
Kafka consumer Api
Kafka 在0.9版本之后将consumer的high-level API和low-level API合并成New Consumer API，正常情况下可以使用这俩种API，但是在Kafka开启SASL认证后只支持New Consumer API进行消费。 pom中改为引入： <dependency> <groupId...
