课程
/后端开发
/Java
/Kafka流处理平台
一直不是很能理解这样,因为在application中配置了kakfa。还要创建两个类来加载配置文件。
2018-09-10
源自:Kafka流处理平台 4-3
正在回答
对应的@Configuration 和@EnableKafka注解的类 就是用来读取properties里的配置的参数
举报
作为模块解耦和大数据处理黏合剂的不二之选Kafka,你值得拥有!
1 回答kafka.consumer.group.id 配置里面这个填什么?
4 回答想请教一下kafka中文乱码问题该如何设置?
2 回答老师好,想问下KafKa已经具有流处理能力,为什么很多项目还都是组合Kafka和Flink, 仅应用KafKa的消息队列特性呢,搞的工序多了一道?
1 回答请问下,我想要控制kafka消费方在接收到消息后,不立即消费;每10秒消费一次,每次消费100条,如何实现呢
3 回答1.kafka元数据有Broker,Topic,Partition,Producer,Consumer,Consumer Group这几个? 2.kafka元数据都存储在zookeepr服务器上, 所以需要使用zookeeper, 具体的消息不在zookeeper上?