----start    游标(Cursor)有点像Java中的List类，用来定义一个集合，并允许遍历这个集合，从而使我们能够处理集合中的单个记录。典型的使用游标的过程如下：一：声明游标语法：DECLARECURSOR [WITHOUT HOLD | WITH HOLD][WITHOUT RETURN | WITH RETURN TO CALLER | WITH RET

– Startpackage demo07;import java.util.List;import org.junit.jupiter.api.Test;import org.mockito.Mockito;@SuppressWarnings("unchecked")class VerifyMethodCalledTest {@Testvoid test() {...

-- StartJava语言规范(Java Language Specification) 和Java虚拟机规范(Java Virtual Machine Specification) 描述了更多的细节, 你可以从下面的网址在线阅读或下载.http://docs.oracle.com/javase/specs/---更多参见：Java 精萃-- 声 明：转载请注明出处-

– Start当我们需要某个对象时，通常的做法是 new 一个对象，然后使用它。使用 Spring 后，套路完全变了，Spring 帮我们创建对象，然后缓存到它的容器中，当我们需要一个对象时，问 Spring 要即可，怎么样？想法是不是非常妙，我们来看个例子吧。首先，定义一个类。package shangbo.spring.example1;public class OutPutServic

– Start废话少说，直接上代码。package shangbo.kafka.example11;import org.springframework.context.ApplicationContext;import org.springframework.context.annotation.AnnotationConfigApplicationContext;pub...

-- Start点击此处观看本系列配套视频总的来说就是消息的生产者(producer)发送消息到某个主题(topic)，消息的消费者(consumer)从这个主题中接收数据。其中 kafka 集群(cluster)可以由多个服务器组成，每个服务器称之为代理(broker).--更多参见：Kafka 精萃--声 明：转载请注明出处-- Last Edited on 2014-...

– Start下面的方法演示将 offset 存储在数据库中，和消息处理放在同一事务中，真正实现 exactly once.创建表CREATE TABLE KAFKA_OFFSET(TOPICVARCHAR2(100),PARTITIONNUMBER(3, 0),OFFSETNUMBER(18, 0));IN...

– Start下面的例子演示了如何发送消息。package shangbo.kafka.example1;import java.util.Properties;import java.util.concurrent.Future;import org.apache.kafka.clients.producer.Callback;import org.apache.kafk...

– Start首先启动 ZooKeeper 和 Kafka borker。下面的例子演示了如何接收数据。package shangbo.kafka.example4;import java.util.Arrays;import java.util.Properties;import org.apache.kafka.clients.consumer.ConsumerRec...

-- Start点击此处观看本系列配套视频登录 Kafka 官方网站（http://kafka.apache.org/）下载 Kafka 最新版本，本系列文章将采用1.1.0 版作为说明。安装 Kafka 非常简单，将它解压缩到某个目录就可以了，本人将使用目录D:\0_Shangbo\App\kafka\kafka_2.12-1.1.0--更多参见：Kafka 精萃-...