This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from d8bb6d5 IOTDB-2414][IOTDB-2419]Fix partial insert failure exception
message && Fix three level aligned path query bug (#4863)
add 3186a0c [IOTDB-2184] Update the code of Kafka example to use Session
API and update kafka version from 0.8.2.0 to 2.8.0 (#4849)
No new revisions were added by this update.
Summary of changes:
example/kafka/pom.xml | 8 +-
example/kafka/readme.md | 30 ++--
.../main/java/org/apache/iotdb/kafka/Constant.java | 68 ++++-----
.../main/java/org/apache/iotdb/kafka/Consumer.java | 129 +++++++++++++++++
.../org/apache/iotdb/kafka/ConsumerThread.java | 159 +++++++++++++++++++++
.../java/org/apache/iotdb/kafka/KafkaConsumer.java | 90 ------------
.../apache/iotdb/kafka/KafkaConsumerThread.java | 104 --------------
.../kafka/{KafkaProducer.java => Producer.java} | 34 +++--
8 files changed, 362 insertions(+), 260 deletions(-)
create mode 100644
example/kafka/src/main/java/org/apache/iotdb/kafka/Consumer.java
create mode 100644
example/kafka/src/main/java/org/apache/iotdb/kafka/ConsumerThread.java
delete mode 100644
example/kafka/src/main/java/org/apache/iotdb/kafka/KafkaConsumer.java
delete mode 100644
example/kafka/src/main/java/org/apache/iotdb/kafka/KafkaConsumerThread.java
rename example/kafka/src/main/java/org/apache/iotdb/kafka/{KafkaProducer.java
=> Producer.java} (60%)
