From 43f7b85feda4d6358bc31df6be3e6ef177ce104a Mon Sep 17 00:00:00 2001 From: CaptainB Date: Thu, 2 Nov 2023 10:37:13 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E5=A2=9E=E5=8A=A0Kafka=E4=B8=AD?= =?UTF-8?q?=E9=97=B4=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/kafka/3.6.0/data.yml | 16 +++++++++++++++ apps/kafka/3.6.0/docker-compose.yml | 30 ++++++++++++++++++++++++++++ apps/kafka/README.md | 9 +++++++++ apps/kafka/data.yml | 19 ++++++++++++++++++ apps/kafka/logo.png | Bin 0 -> 3882 bytes 5 files changed, 74 insertions(+) create mode 100644 apps/kafka/3.6.0/data.yml create mode 100644 apps/kafka/3.6.0/docker-compose.yml create mode 100644 apps/kafka/README.md create mode 100644 apps/kafka/data.yml create mode 100644 apps/kafka/logo.png diff --git a/apps/kafka/3.6.0/data.yml b/apps/kafka/3.6.0/data.yml new file mode 100644 index 000000000000..ce5e54b88ba5 --- /dev/null +++ b/apps/kafka/3.6.0/data.yml @@ -0,0 +1,16 @@ +additionalProperties: + formFields: + - default: 9092 + envKey: KAFKA_PORT + labelEn: Port + labelZh: TCP 端口 + required: true + rule: paramPort + type: number + - default: '127.0.0.1' + envKey: KAFKA_HOST + labelEn: Host + labelZh: Host/IP + required: true + rule: paramCommon + type: text diff --git a/apps/kafka/3.6.0/docker-compose.yml b/apps/kafka/3.6.0/docker-compose.yml new file mode 100644 index 000000000000..adfef81cf650 --- /dev/null +++ b/apps/kafka/3.6.0/docker-compose.yml @@ -0,0 +1,30 @@ +version: '3' +services: + kafka: + container_name: ${CONTAINER_NAME} + restart: always + environment: + ALLOW_PLAINTEXT_LISTENER: 'yes' + KAFKA_CFG_LOG_RETENTION_MS: 60000 + KAFKA_CFG_MAX_REQUEST_SIZE: 524288000 + KAFKA_CFG_MESSAGE_MAX_BYTES: 524288000 + KAFKA_CFG_REPLICA_FETCH_MAX_BYTES: 524288000 + KAFKA_CFG_FETCH_MESSAGE_MAX_BYTES: 524288000 + KAFKA_CFG_PARTITION_FETCH_BYTES: 524288000 + KAFKA_CFG_NODE_ID: 0 + KAFKA_CFG_PROCESS_ROLES: controller,broker + KAFKA_CFG_LISTENERS: PLAINTEXT://:9092,CONTROLLER://:9093 + KAFKA_CFG_ADVERTISED_LISTENERS: PLAINTEXT://${KAFKA_HOST}:${KAFKA_PORT} + KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP: CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT + KAFKA_CFG_CONTROLLER_QUORUM_VOTERS: 0@127.0.0.1:9093 + KAFKA_CFG_CONTROLLER_LISTENER_NAMES: CONTROLLER + networks: + - 1panel-network + ports: + - "${KAFKA_PORT}:9092" + image: bitnami/kafka:3.6.0 + labels: + createdBy: "Apps" +networks: + 1panel-network: + external: true diff --git a/apps/kafka/README.md b/apps/kafka/README.md new file mode 100644 index 000000000000..4e6be6834094 --- /dev/null +++ b/apps/kafka/README.md @@ -0,0 +1,9 @@ +# Kafka + +Kafka 一个分布式流处理平台 + +## 主要功能： + +- 它能够让应用发布或预订数据或事件流。 +- 它能够以可容错的持久方式准确地存储记录（即，按照记录的出现顺序）。 +- 它能够实时处理记录（一出现便处理）。 diff --git a/apps/kafka/data.yml b/apps/kafka/data.yml new file mode 100644 index 000000000000..87fe1852852d --- /dev/null +++ b/apps/kafka/data.yml @@ -0,0 +1,19 @@ +name: Kafka +tags: + - 中间件 +title: Kafka 一个分布式流处理平台 +type: 中间件 +description: Kafka 是一个分布式流处理平台 +additionalProperties: + key: kafka + name: Kafka + tags: + - Middleware + shortDescZh: Apache Kafka 是一种分布式数据存储，经过优化以实时提取和处理流数据。流数据是指由数千个数据源持续生成的数据，通常可同时发送数据记录。流平台需要处理这些持续流入的数据，按照顺序逐步处理。 + shortDescEn: Apache Kafka is a distributed data store optimized for ingesting and processing streaming data in real-time. Streaming data is data that is continuously generated by thousands of data sources, which typically send the data records in simultaneously. A streaming platform needs to handle this constant influx of data, and process the data sequentially and incrementally. + type: tool + crossVersionUpdate: false + limit: 0 + website: https://kafka.apache.org/ + github: https://github.com/apache/kafka + document: https://kafka.apache.org/documentation/ \ No newline at end of file diff --git a/apps/kafka/logo.png b/apps/kafka/logo.png new file mode 100644 index 0000000000000000000000000000000000000000..3576e5c511ea8d839b46616281d2d3d75a575cc6 GIT binary patch literal 3882 zcmV+_57qFAP)Af_SA%RKDkw4H1MmqdqU;*@BQmlqJCEJjUC(#woO`S9^zEKmrk9?jPIC8lSDmUl zRbQP`r%qMR)@p$Q1qu`>P@o5jhRO+nRwu2^vg|N=uhH+DHf?%{_dU=mqM@u-1DKVR z)fntRtAuhh+p_j)No>zgjJZBF=1*yCewIejhpn|o2ulEV6;KXn636E>josg}$$q@~ zGd)xEo$~G@pidUo0PKL%TKvTxKTRX^U->>S0MAWKOgvet2+q?05}V#;WNw0Hrcu0y-*t0_ zG7Jw7KazmGOn{wXQ(TWfgFNwy0}T+dmf5i}LtyQN*#&T|*lyN*+1fDCn))wYXNmWB zk{tH214eEwwe~0nl$mF3jO>X>S3oBxCm)J8ndl2eTk+gcuh$roxPk=yuAO?j%x=OTg7VjiB-`h~HH7=W?C0Fb>fo; zp79^lgLclAxda+*j2WY{Z>IDeZQCYVr=^ZwW|;TNVoiGS_LGKK4wj|O;dAMfCh3Dm z8X>}Vg-q>Th#rxX^aC%?*DfC9No$`ffH@6~%w--A6M^{r5~vp-z2s<>X;3`ns>!r! zEDaAbY1osJ*xoIsb1TwhznTxU0z#(u^}@$m+O+mrNSA%=8l5QQG5}( zw}T0j81q{4re8zlUr=T`2$XyD)~3eOQ7j0vd@ z69{LgB>ew)owWAqc0O581=J);-X@^#X3$2P8-$eyL_wv2xEgz0HqQjG@O12aF%itg z>(l0bcY0+0CfOa!^nsiM2#U>iSS`rDA)Q2k<{iib(2!3ZO!YZx)syw0QNA{kW=v5B zEYcn$MLpp%bsMF}^=;4%qFY08T*nZbF z-FY3#CycS@>G2;8;BO@RV1erVg~;5*%aHTpozq8_19|j5N&8OE3^Z5DKA@oH14Pcz zCn2D>tpTWe(FuHa2j%u|jSc7JOyg6oqrCM&xjC8?FV=i)VOUGu!0;(gv)*_+@~YNU zO>f2aD}_Av2Fdn8#o(zEg?FdH6lcacTN#`hSHITd*U`33gM%nzF(=;r#h9S$)~$OK z@?mzRUl^zPD2gVeyvl(#v|hh{pN6tRCgzdPejR1`x{{lXvAtAG9Du~E>uFR7Su)FJEXoxKhNmI!K92lF}w$V#d>Iz)LMP^{xl zcD^{UAHIgi(+kv&eJfE_ADF5peI;oD(xQ(Gpa5<`Z#cN`_AYcrzVFk{VUYEayj|q= z{!>09=-^ENxj7;Hp2Jfqa1T)Pbscf*W@KN=p-gLEmc+@^g$0A^fI+A;j!!3^Z;%{Y z>3um(#xwQK745s$W1mgw$K!AVX&Xrs`JltvPZSf|?xD0dflt9BtM%$mpk|)mK@QZ5 z8d2j|ys5qy)&y*C!mU9)RQ{{11hm`0dA0f`ROdR#M`e$rz8*)G;t^7A(WK!HH=E5w z23>^a4(xyISOjLAF!^B|3SMBzcBZ;hdbhIRgg~i)4~XOL@7wko#f-sH2JWUaaqa3`M0#uzSQWz z04(jGbl{#=tJP>@7J|vmJ4x#&%F&GaSecJ!J?&MA|IaC|#2E8)68?jvRgXh{)&o#b zH&BI!;J~yD%Z@14f(A&`fg}EN#RB1Rcdkl<$Cv47nNR@f^Y2j>UM%yw`g2ej9GU>| z_`!$mj1Q`3evx;cOq5;RrU0t)(Kx+QcLR_Q^{afE&Uv)`OP%#Y8*>{cCL(E~lmCD< z!~Rt&WzUsn;HgL#71woPZ9cPN^L^3h^>aVr0fGY44yG(i(|J{L25E!&PpLNhVrliy#J>5WqjCaq&hypr%vPJ zlPm{$!9J){qoWq-*eM90&M_o2j&uc7Zky=tf}JpW-wtmd%OSP%%~TIl;=Fy9vkFxH zg7pY9RVqe-on=QrNe9_;44fd5xmH;G2Ff8b4L~ef1FEPKsMO|-lD1g}Ok{A|3mq`D zMS0t$3@;HnS$)EqiA#0dce$ITnpzX{SvX4Wx(|VNxK~BlQQGV7bJ>%0;`5GyG*;Nv ztHu8N+rr~cz9hot6R;rpe#QOBcNRTB-7r2Li{rzG;}{4XnA&0h+!|%fbA*>Qq{rS7 zY5FXSI)RGAd(yJAT(tvAYI)#b`TbE))hliX&F;~q z$upsvk7pY4$mf0T@WOrzd^I=bZlbW`CVO_*wq7{kb|GgjUz$Fe^8Zt4YY$M%nu^c8 zG}T6tdV7_cn)N|b)8Yt^2iTdV_)MQyfq;4Sv}eco`1s?c+O|O`_|0`(p9iYe36I(b zRR>fD-2;_Rr=(3?3oqBUY96TGL~_9zaURRtE1ftn-L4H zYbx<=@wH$HYiir~>;TtP41fTt1Bj4Z)92MUE~T?<0Lhr^rOL8gMffs~&&m0FfC}q| z^hKbGdGyCpt%!n?*BQsBc$01xy9}h)7R$(!09&?B6RTF{&l@o2i@H9EKr7(=Hcp^= zzeDTBUucm2!J4oF-Y*;_fTUVQ_1;=5I>u2Wd{{21_}x$ys8s&tO9GYGWnQ1R z(sx+l%;In5*vQHxn6B z#I;4v`vEG(W7Z6tF~7dl9YS!so_v|)Ey?`Sr2B$vV+rOr7o4=MBBC^}-eDnlbwnvC zLWUe>^z!hmKt##>k<+5+UAkRx^~a|mT_Y`+IMS|LB4~@ibqesPJ6}$$JyD#MHb?0I zKxOZ@IWqDDOmLBx&zA|5i~KU+p}c!AF5EUvR-}W<^05c(oGKZ|9-s=b^8zpJKw`g? zcDn+nvo8k^rqacJr-f&wV!x1=BUh;#%=wA-j;^J&Z6c4mj#D?MX;~$S=Ins%EO7l7fAB_1o zwRa)nzAhqXb`|pV4nC9#z%sZvPsKn|1-E&P&SO9jB>_O-%W4PdJXM_-$YIQHk(QgW z!Ykx398Jp4`S~2C>k%eIS=0+2`OX0jZJ)hgm(GV29kw(a>XZCgFZRoUc(Q0aweF<2 z7{Fj?kV4vB940I#>@TH$wxUY~l_{$gS|b}|IWmiX+|K8K$Opc!Hy`Xp2xbegH%s=A z@40Hg9B;&8k)DZ+FoUU>I2}O9Ao9+UOh;id=9w9PvPJb3H45ucL&R!Ph+@+`f~+)@TRpM`Dg?3b&#Q>LM$Q$ z0E3k-^)_Ln@f2q!s&5lQBZNoq0k6bu!m9j56R(QO+lUfX)vwemAJmJdt9-rW?@3wF zz!0_x=`!y9Cgpp-xG+WmdS;ee02(rmO6N1bRkS4vaWTJ^~winUKP(!R>;KtkjbXJOKGDcF|)-jg4k>qZNgLB(2vZu zx@Kg$uF4yBU&@qk==-1LhJJjdwAl%OKr2BqgL8*RG>U&q)TTdH}=e6x2!(V4v)x_FU{yR!=Xf)qnGjX(5I8EX2C=D_(D5-bE z!|!_h9%TrB@obe*ron?Qf1A*Y0qZ@X+3>ds2cLLtZNzpnP6J?u0UR_|e?|xm)w5Pi z0Pt(jBG6z`zAoZs9fOIrRn|}UTNoEjQb23nw=RJOgmPfRU*z8YobpK!E}UdQi~+0nDW!xao&0KmY&$07*qoM6N<$f@#xu1ONa4 literal 0 HcmV?d00001