问题导读 1.如何干净利落地退出轮询？2.退出可以调用哪些方法？3.退出代码是什么样的？ But How Do We Exit? 但是我们 ...

feilong 2017-7-21 2 12519

问题导读 1.Kafka提供了Producer类作为java producer的api,此类有几种发送方式？ 2.总结调用producer.send方法包含哪些流程？ ...

pig2 2014-11-11 2 35037

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

feilong 2017-8-4 2 9661

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

feilong 2017-7-28 1 7551

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

levycui 2017-7-18 1 10228

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

坎蒂丝_Swan 2015-1-8 4 49537

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

xingoo 2017-7-16 1 8162

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

feilong 2017-7-14 1 7993

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

desehawk 2017-7-12 2 8562

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

xingoo 2017-7-8 1 7093

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

feilong 2017-7-7 2 10210

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

PeersLee 2017-7-5 1 7520

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

levycui 2017-7-4 1 8258

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

fc013 2017-7-1 2 24734

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

xingoo 2017-7-1 2 11608

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

feilong 2017-6-30 3 28770

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

xingoo 2017-5-2 6 24030

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

desehawk 2017-6-27 1 9183

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

pig2 2017-6-26 1 8673

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

fc013 2017-6-24 1 13822

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

feilong 2017-6-23 3 12731

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

desehawk 2014-11-5 4 73497

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

xingoo 2017-6-18 2 8564

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

feilong 2017-6-16 1 8762

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

xingoo 2017-6-11 3 9257

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

levycui 2017-6-6 3 9904

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

xingoo 2017-6-4 1 8655

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

feilong 2017-6-2 1 7314

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

xingoo 2017-5-28 0 11876