问题导读 1.为什么需要在没有消费组的情况下使用独立消费者？ 2.怎样没有消费组的情况下使用独立消费者？ 3.具体代码如何编 ...

feilong 2017-8-4 2 9840

问题导读 1.什么是序列化，反序列化？ 2.kafka中使用串行器、解释器要注意什么？ 3.如何自定义解释器？ 4.消费者端如何 ...

feilong 2017-7-28 1 7567

本帖最后由 levycui 于 2017-7-18 14:21 编辑 问题导读： 1、轮询循环处理哪些工作？ 2、消费者主体关注哪些内容？ 3、cons ...

levycui 2017-7-18 1 10245

本帖最后由 坎蒂丝_Swan 于 2015-1-8 15:00 编辑 问题导读 1.Kafka系统由什么组成？ 2.Kafka中和producer相关的API是什么 ...

坎蒂丝_Swan 2015-1-8 4 49651

问题导读： 1 生产者中都有哪些有用的配置？ 2 如何保证生产者消息的顺序性？ 3 如何提高生产者发送消息的吞吐量？ ...

xingoo 2017-7-16 1 8183

问题导读 1.如何从任意位置读取偏移量，消费消息？2.seek()方法如何使用？ 到目前为止，我们已经看到了如何使用poll( ...

feilong 2017-7-14 1 8007

问题导读 1.kafka的消费者组的消费偏移存储，kafka支持两个版本? 2.ConsumerOffsetChecker类的作用是什么？ 3.Kafka如何通 ...

desehawk 2017-7-12 2 8586

问题导读 1 生产者中消息时如何决定写入哪个分区中的? 2 如何自定义分区器? 在前面的例子中，创建ProducerRecord对象 ...

xingoo 2017-7-8 1 7108

问题导读 1.什么是异步提交？2.人工提交的缺点是什么？异步提交的缺点是什么？3.怎样合并同步和异步提交？4.怎样提交指定的偏移 ...

feilong 2017-7-7 2 10231

问题导读: 1. 该体系如何架构? 2. 如何与Apache Sentry集成? 解决方案: 随着在CDH平台上物联网（IoT）使用案例的 ...

PeersLee 2017-7-5 1 7546

问题导读： 1、什么是Producer拦截器？ 2、Intercetpor包含哪些方法？ 3、如何实现双interceptor组成的拦截链？ 4、如何利用 ...

levycui 2017-7-4 1 8281

问题导读： 1.Kafka0.11版本主要有哪些功能变更？2.Kafka0.11版本增加了哪个分配算法？3.Kafka0.11版本怎样重构的controll ...

fc013 2017-7-1 2 24751

问题导读： 1 如何自定义Kafka序列化？ 2 如何使用Avro进行序列化？ 在前面的例子中，producer必须要设置序列化。 ...

xingoo 2017-7-1 2 11639

本帖最后由 feilong 于 2017-6-30 08:16 编辑 问题导读 1.什么是一次提交（commit）？2.什么是偏移量（offset）？3.消费者如 ...

feilong 2017-6-30 3 28788

本帖最后由 xingoo 于 2017-5-7 21:38 编辑 问题导读： 1 kafka中的消息单元：Message和batch 2 kafka中的消息格式：sch ...

xingoo 2017-5-2 6 24256

问题导读 1.kafka发送消息有哪三种方式？ 2.kafka三种发送消息方式各有什么特点？ 3.kafka三种发送消息方式是如何实现的？ ...

desehawk 2017-6-27 1 9205

[mw_shl_code=bash,true]kafka-console-consumer.sh --zookeeper master:2181,slave1:2181,slave2:2181 --topic aboutyunlog ...

pig2 2017-6-26 1 8686

问题导读： 1.Selector有哪些功能？2.Selector怎样保存内部状态信息？3.Selector为什么比直接使用NIO好？ org ...

fc013 2017-6-24 1 13858

本帖最后由 feilong 于 2017-6-23 12:04 编辑 问题导读 1.什么情况下需要Rebalance Listeners？ 2.ConsumerRebalanceListe ...

feilong 2017-6-23 3 12748

问题导读 1.什么是gradle，作用是什么？ 2.如何用gradle构建产生IDEA工程文件？ 3.log4j.properties该如何设置？ ...

desehawk 2014-11-5 4 73534

问题导读： 1 如何创建Kafka的生产者？ 2 发送数据都有哪几种方式？ 向Kafka中写入数据的第一步就是创建生产者对象， ...

xingoo 2017-6-18 2 8654

问题导读 1.为什么要先讲解一些Kafka的概念？2.Kafka消费者和消费组的概念是什么？两者有什么关系？3.Kafka如何实现负载均衡？ ...

feilong 2017-6-16 1 8824

问题导读： 1 Producer是如何把数据写入broker的？ 2 Producer在使用中都需要注意哪些问题？ 虽然producer的API ...

xingoo 2017-6-11 3 9283

本帖最后由 levycui 于 2017-6-6 15:06 编辑 问题导读： 1、kafka如何优化垃圾回收选项？ 2、生产环境中如何考虑kafka集群容 ...

levycui 2017-6-6 3 9928

问题导读： 1 什么是Kafka的生产者？ 2 Kafka都有什么使用场景？ 3 消息写入kafka时，需要考虑什么问题？ 无论你把K ...

xingoo 2017-6-4 1 8671

kafka一个常见的安装是在像亚马逊网络服务的云计算环境中。由于有各种不同类型的可用实例，为选择正确的实例配置使用，kafka ...

feilong 2017-6-2 1 7329

问题导读： 1 Kafka集群有什么优势？ 2 集群中部署多少个节点合适？ 3 集群针对系统如何调优？ Kafka集群 对于本 ...

xingoo 2017-5-28 0 11909

问题导读： 1 Kafka的对于硬件环境有什么要求？ 2 Kafka如何选择硬件以调整Kafka的性能？ 硬件选择 kafka的broker ...

xingoo 2017-5-21 5 17410

本帖最后由 zxczhkzxc 于 2017-5-9 17:51 编辑 问题导读： 1 如何理解kafka的多个生产者模式？ 2 如何理解kafka的多个消 ...

zxczhkzxc 2017-5-8 2 8954