# wkafka

**Repository Path**: wyb199104/wkafka

## Basic Information

- **Project Name**: wkafka
- **Description**: No description available
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 1
- **Forks**: 0
- **Created**: 2020-11-05
- **Last Updated**: 2020-12-19

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# wkafka

#### 介绍

producer：
1.  封装了producer的配置，提供常用生产模式的一键配置；
2.  封装了三种消息发送模型：发送并遗忘、同步发送和异步发送；
3.  提供三种常用的发送失败消息的处理模型：单条处理、批量处理、带反压机制的批量处理；支持自定义失败消息处理模型；

consumer：
1.  封装了consumer的配置，提供常用消费模式的一键配置；
2.  支持group consumer和standalone两种消费模式；
3.  封装了at-most/at-least/exactly-once（仍然需要用户保证幂等处理）三种语义；
4.  封装了四种FirstFetchStrategies；
5.  封装了默认的rebalanceListener；
6.  支持standalone模式手动配置rebalance；
7.  暂没有实现使用外部系统管理offset；

#### 使用说明

1.  创建kafkaProducerProps或kafkaConsumerProps
2.  创建WKafkaProducer或WKafkaConsumer