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

Posted to commits@kafka.apache.org by gu...@apache.org on 2020/02/06 00:51:31 UTC

[kafka] branch trunk updated (987f0ee -> 9d17bf9)

This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 987f0ee  KAFKA-8164: Add support for retrying failed (#8019)
     add 9d17bf9  KAFKA-9447: Add new customized EOS model example (#8031)

No new revisions were added by this update.

Summary of changes:
 .../kafka/clients/admin/DescribeTopicsResult.java  |  23 +--
 .../kafka/clients/admin/ListTopicsResult.java      |  14 +-
 examples/README                                    |   8 +-
 ...imple-consumer-demo.sh => exactly-once-demo.sh} |   7 +-
 .../src/main/java/kafka/examples/Consumer.java     |  32 +++-
 .../examples/ExactlyOnceMessageProcessor.java      | 209 +++++++++++++++++++++
 .../kafka/examples/KafkaConsumerProducerDemo.java  |  14 +-
 .../java/kafka/examples/KafkaExactlyOnceDemo.java  | 185 ++++++++++++++++++
 .../src/main/java/kafka/examples/Producer.java     |  42 ++++-
 9 files changed, 489 insertions(+), 45 deletions(-)
 copy examples/bin/{java-simple-consumer-demo.sh => exactly-once-demo.sh} (91%)
 create mode 100644 examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java
 create mode 100644 examples/src/main/java/kafka/examples/KafkaExactlyOnceDemo.java