You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@iotdb.apache.org by ro...@apache.org on 2022/01/17 14:16:31 UTC

[iotdb] branch master updated (d8bb6d5 -> 3186a0c)

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%)