irc-kafka:使用Apache Kafka的Chat Client应用程序

时间:2024-05-21 05:17:59
【文件属性】:

文件名称:irc-kafka:使用Apache Kafka的Chat Client应用程序

文件大小:312KB

文件格式:ZIP

更新时间:2024-05-21 05:17:59

Java

卡夫卡聊天 与Apache Kafka进行简单的IRC聊天 会员 13512078 Ramandika Pranamulia 13512086 Stanley Santoso 概念 每个昵称将是消费者组中的客户。 该消费者组将订阅一些特定主题,仅包含一个分区。 用户加入的频道列表将不会保存在Kafka中,唯一保存的频道是消费者群通过zookeper收到的消息的偏移量。 因此,如果用户注销并使用相同的昵称加入,则他/她将收到一条消息,指出他/她在注销时已经落后。 Assume stanley joins pat and if4031 When a user types `/JOIN` or `/LEAVE`, it will create a connector for that specific channel and save it into Map<String,Connector


【文件预览】:
irc-kafka-master
----src()
--------main()
----Readme.md~(3KB)
----pom.xml(975B)
----Readme.md(3KB)
----target()
--------classes()
--------irc-kafka-1.0-SNAPSHOT.jar(8KB)
--------maven-archiver()
--------maven-status()
----.idea()
--------misc.xml(1KB)
--------libraries()
--------workspace.xml(43KB)
--------vcs.xml(164B)
--------uiDesigner.xml(9KB)
--------copyright()
--------compiler.xml(1KB)
--------.name(9B)
--------modules.xml(258B)
----testcase.png(279KB)
----irc-kafka.iml(2KB)

网友评论