# kafka_complication_demo

**Repository Path**: brother_bingo/kafka_complication_demo

## Basic Information

- **Project Name**: kafka_complication_demo
- **Description**: kaflka技术内幕代码
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2021-11-04
- **Last Updated**: 2021-11-04

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README


# awesome-kafka

## awesome-awesome

- [awesome-bigdata](<https://github.com/onurakpolat/awesome-bigdata>)
- [awesome-streaming](<https://github.com/manuzhang/awesome-streaming>)
- [awesome-spark](<https://github.com/awesome-spark/awesome-spark>)
- [awesome-flink](<https://github.com/wuchong/awesome-flink>)
- [awesome-kafka](<https://github.com/infoslack/awesome-kafka>)

## Blogs

- [The Log](<https://engineering.linkedin.com/distributed-systems/log-what-every-software-engineer-should-know-about-real-time-datas-unifying>) [中文翻译](<https://github.com/oldratlee/translations/tree/master/log-what-every-software-engineer-should-know-about-real-time-datas-unifying>)

## Book

- [I Heart Logs](<http://shop.oreilly.com/product/0636920034339.do>)
- [Kafka The Definive Guide](<http://shop.oreilly.com/product/0636920044123.do>)
- [Learning Apache Kafka](<https://www.packtpub.com/big-data-and-business-intelligence/learning-apache-kafka-second-edition>)
- [Making sense of stream processing](<http://www.confluent.io/making-sense-of-stream-processing-ebook>)
- [Designing Data-Intensive Applications](<http://shop.oreilly.com/product/0636920032175.do>)

## Papers & Presentations & Resources

- [Kafka Papers](<https://cwiki.apache.org/confluence/display/KAFKA/Kafka+papers+and+presentations>)
- [Samza Papers](<https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=51812876>)
- [Confluent Resources](<https://www.confluent.io/resources/>)

## Wiki

- [Kafka Improvement Proposals](<https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals>)
- [Samza Enhancement Proposal](<https://cwiki.apache.org/confluence/display/SAMZA/Samza+Enhancement+Proposal>)
- [Flink Improvement Proposals](<https://cwiki.apache.org/confluence/display/FLINK/Flink+Improvement+Proposals>)

## Monitor

- [kafka-manager](<https://github.com/yahoo/kafka-manager>)
- [kafka-eagle](<https://github.com/smartloli/kafka-eagle>)
- [Burrow - Kafka Consumer Lag Checking](<https://github.com/linkedin/Burrow>)

## Who Use & Contribute to Kafka

- [Confluent](<https://github.com/confluentinc>)
- [LinkedIn](<https://github.com/linkedin?utf8=%E2%9C%93&q=kafka&type=&language=>)
- [Uber](<https://github.com/uber?utf8=%E2%9C%93&q=kafka&type=&language=>)
- [Datamountaineer](<https://github.com/datamountaineer>)
- [Landoop](<https://github.com/Landoop>)

## OpenSource MQ

- [Pulsar - distributed pub-sub messaging system](<https://github.com/yahoo/pulsar>)
- [hermes - Ctrip asynchronous message queue solution](<https://github.com/taotaoideas/hermes>)


## Based On Kafka

- [Hermes - Fast and reliable message broker](<https://github.com/allegro/hermes>)
- [kafka-metrics: Real-time aggregation of metrics](<https://github.com/amient/kafka-metrics>)
- [Oryx 2: Lambda architecture](<https://github.com/OryxProject/oryx>)
- [Seldon](<https://github.com/SeldonIO/seldon-server>)

---

## Project Code In This Repository

### kafka examples

- [x] kafka consumer
- [x] kafka producer
- [ ] kafka connect
- [x] kafka streams
- [ ] [confluent-examples](<https://github.com/confluentinc/examples>)

### 3rd clients & Reactive

- [ ] [reactive-kafka](<https://github.com/akka/reactive-kafka>) - Akka Streams connector for Apache Kafka
- [ ] [reactor-kafka](<https://github.com/reactor/reactor-kafka>)
- [ ] [kafka-rx](<https://github.com/cjdev/kafka-rx>)
- [x] [spring-integration-kafka](<https://projects.spring.io/spring-kafka/>)

### applications

- [x] [kafkastreams-cep](<https://github.com/fhussonnois/kafkastreams-cep>)
- [x] [kafka-streams-drools](<https://github.com/benwatson528/kafka-streams-drools>)
- [x] [siddhi-kafka-cep](<https://github.com/sbcd90/siddhi-kafka-cep>)

### bigdata

- [ ] [kafka-spark-consumer](<https://github.com/dibbhatt/kafka-spark-consumer>)
- [x] [spark-kafka](<https://github.com/tresata/spark-kafka>)
- [x] [spark-streaming-kafka](<http://spark.apache.org/docs/latest/streaming-kafka-integration.html>)
- [ ] [structured-streaming-kafka](<https://spark.apache.org/docs/latest/structured-streaming-kafka-integration.html>)
- [x] [flink-kafka-connector](<https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/connectors/kafka.html>)
- [ ] [storm-kafka(0.8)](<https://github.com/apache/storm/tree/master/external/storm-kafka>)
- [ ] [storm-kafka-client(0.10)](<https://github.com/apache/storm/tree/master/external/storm-kafka-client>)
- [ ] [samza-kafka](<>)
- [ ] [beam-kafka](<https://github.com/apache/beam/tree/master/sdks/java/io/kafka>)
- [ ] [ignite-kafka](<https://apacheignite-mix.readme.io/docs/kafka-streamer>)
- [ ] [gearpump-kafka](<http://gearpump.apache.org/releases/latest/dev/dev-connectors/index.html>)