axon-kafka:Kafka作为AxonFramework 3的EventBus和EventStore-源码

Java

Axon Kafka Eventstore 目标该项目的目标是实现基于Kafka的EventStore。结构该项目由axon-kafka库和一些示例组成。示例由发送者和接收者组成。发送方正在提供REST API（使用Swagger调用）并创建一些通知。每个创建都会以一个通知ID进行响应，该通知ID可用于更改通知状态。惯例/想法 axon-kafka库应仅依赖于Kafka和AxonFramework。示例是使用SpringBoot实现的。将有axon-kafka-springboot组件，以方便使用Axon Kafka（后）。进度/功能 Kafka发件人已实现并发送消息

文件下载

资源详情

[{"title":"（ 40 个子文件 44KB ） axon-kafka:Kafka作为AxonFramework 3的EventBus和EventStore-源码","children":[{"title":"axon-kafka-master","children":[{"title":"axon-kafka","children":[{"title":"src","children":[{"title":"test","children":[{"title":"java","children":[{"title":"org","children":[{"title":"axonframework","children":[{"title":"config","children":[{"title":"kafka","children":[{"title":"KafkaConfigBuilderTest.java <span style='color:#111;'> 1.76KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"main","children":[{"title":"java","children":[{"title":"org","children":[{"title":"axonframework","children":[{"title":"eventhandling","children":[{"title":"tokenstore","children":[{"title":"kafka","children":[{"title":"KafkaTokenStore.java <span style='color:#111;'> 3.68KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true},{"title":"config","children":[{"title":"kafka","children":[{"title":"KafkaConfigBuilder.java <span style='color:#111;'> 5.40KB </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"eventsourcing","children":[{"title":"eventstore","children":[{"title":"kafka","children":[{"title":"KafkaEventStoreEngine.java <span style='color:#111;'> 5.72KB </span>","children":null,"spread":false},{"title":"KafkaStorageConverter.java <span style='color:#111;'> 5.78KB </span>","children":null,"spread":false},{"title":"KafkaDomainEventEntry.java <span style='color:#111;'> 500B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true},{"title":"messaging","children":[{"title":"kafka","children":[{"title":"DefaultSubscribableEventSource.java <span style='color:#111;'> 691B </span>","children":null,"spread":false},{"title":"Sender.java <span style='color:#111;'> 180B </span>","children":null,"spread":false},{"title":"message","children":[{"title":"KafkaMessageConverter.java <span style='color:#111;'> 5.65KB </span>","children":null,"spread":false},{"title":"KafkaMessage.java <span style='color:#111;'> 863B </span>","children":null,"spread":false}],"spread":false},{"title":"KafkaMessageSource.java <span style='color:#111;'> 1.37KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"README.MD <span style='color:#111;'> 138B </span>","children":null,"spread":false},{"title":"pom.xml <span style='color:#111;'> 957B </span>","children":null,"spread":false}],"spread":true},{"title":"README.MD <span style='color:#111;'> 808B </span>","children":null,"spread":false},{"title":"examples","children":[{"title":"axon-kafka-receiver","children":[{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"application.yml <span style='color:#111;'> 109B </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"org","children":[{"title":"axonframework","children":[{"title":"kafka","children":[{"title":"example","children":[{"title":"receiver","children":[{"title":"AxonConfiguration.java <span style='color:#111;'> 2.25KB </span>","children":null,"spread":false},{"title":"MessagingConfiguration.java <span style='color:#111;'> 1.58KB </span>","children":null,"spread":false},{"title":"AxonKafkaReceiverApplication.java <span style='color:#111;'> 537B </span>","children":null,"spread":false},{"title":"query","children":[{"title":"NotificationLoggingListener.java <span style='color:#111;'> 646B </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 2.40KB </span>","children":null,"spread":false}],"spread":true},{"title":"kafka","children":[{"title":"prepare-topics.sh <span style='color:#111;'> 560B </span>","children":null,"spread":false}],"spread":true},{"title":"axon-kafka-sender","children":[{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"application.yml <span style='color:#111;'> 124B </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"org","children":[{"title":"axonframework","children":[{"title":"kafka","children":[{"title":"example","children":[{"title":"sender","children":[{"title":"SenderConfiguration.java <span style='color:#111;'> 6.27KB </span>","children":null,"spread":false},{"title":"event","children":[{"title":"NotificationEventHandler.java <span style='color:#111;'> 470B </span>","children":null,"spread":false}],"spread":false},{"title":"model","children":[{"title":"Notification.java <span style='color:#111;'> 1.54KB </span>","children":null,"spread":false}],"spread":false},{"title":"AxonKafkaSenderApplication.java <span style='color:#111;'> 360B </span>","children":null,"spread":false},{"title":"messaging","children":[{"title":"KafkaFakeSender.java <span style='color:#111;'> 590B </span>","children":null,"spread":false}],"spread":false},{"title":"rest","children":[{"title":"Notification.java <span style='color:#111;'> 165B </span>","children":null,"spread":false},{"title":"CommandEndpoint.java <span style='color:#111;'> 2.18KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 2.41KB </span>","children":null,"spread":false}],"spread":true},{"title":"axon-kafka-common","children":[{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"org","children":[{"title":"axonframework","children":[{"title":"kafka","children":[{"title":"example","children":[{"title":"sender","children":[{"title":"api","children":[{"title":"NotificationMarkedEvent.java <span style='color:#111;'> 249B </span>","children":null,"spread":false},{"title":"NotificationCreatedEvent.java <span style='color:#111;'> 257B </span>","children":null,"spread":false},{"title":"CreateNotificationCommand.java <span style='color:#111;'> 382B </span>","children":null,"spread":false},{"title":"NotificationState.java <span style='color:#111;'> 103B </span>","children":null,"spread":false},{"title":"MarkNotificationCommand.java <span style='color:#111;'> 365B </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 874B </span>","children":null,"spread":false}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 2.31KB </span>","children":null,"spread":false}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 2.18KB </span>","children":null,"spread":false},{"title":"docker-compose.yml <span style='color:#111;'> 193B </span>","children":null,"spread":false},{"title":".gitignore <span style='color:#111;'> 112B </span>","children":null,"spread":false}],"spread":true}],"spread":true}]

评论信息

其他资源

免责申明

【只为小站】的资源来自网友分享，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，【只为小站】无法对用户传输的作品、信息、内容的权属或合法性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论【只为小站】经营者是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。
本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二条之规定，若资源存在侵权或相关问题请联系本站客服人员，zhiweidada#qq.com，请把#换成@，本站将给予最大的支持与配合，做到及时反馈和处理。关于更多版权及免责申明参见版权及免责申明