ใซใใซใใผใใงใฏใใฌใคใ - ใณใใฏใ็ทจ
ใซใใซใปใณใใฏใใซ้ขใใๆทฑใ็่ซใฎ่ชฌๆใจใ็พๅ ดใงใใใซไฝฟใใใฌใใซใฎ่ฉณ็ดฐใชๅฎ่ทตใ้ใใฆใ็พๅ ดใงๅฟ ่ฆใจใใใซใใซใปใณใใฏใใใผในใฎใใผใฟ้ฃๅใใใณใใผใฟใใคใใฉใคใณๆง็ฏใฎๅฐ้ๅฎถใซๆ้ทใใใฆใใใพใใ ใ
ๅ่ฌ็ 792ๅ
้ฃๆๅบฆ ไธญ็ดไปฅไธ
ๅ่ฌๆ้ ็กๅถ้

- ๆช่งฃๆฑบ
๊ณ์ csvํ์ผ์ ํด๋๋ก ์ธ์ํ๋ ์ค์ ๋๋ค.
๊ณ์ csvํ์ผ์ ํด๋๋ก ์ธ์ํ๋ ์ค์ ๋๋ค. ์ด๋ฌํ ๋ฌธ์ ์๋ํ ํด๊ฒฐ๋ฐฉ๋ฒ์ ์๋ ค์ฃผ์ จ์ผ๋ฉด ํฉ๋๋ค.๊ณ์ finished ํด๋์์ test-01.csvํด๋๊ฐ์๊ธฐ๊ณ ๊ทธ์์
kafka๋ฐ์ดํฐ-์์ง๋์ด๋งgimhansu8038
ใป
4ใถๆๅ
0
58
2
- ๆช่งฃๆฑบ
cdc failover
์๋ ํ์ธ์ cdc๋ฅผ ํ์ ์ ์ ์ฉ์ํค๋ ค๊ณ ํ๋๋ฐ ๋ ธํ์ฐ๊ฐ ์์ด ๋ฌธ์ ๋๋ฆฝ๋๋ค. ํ์ฌ maria d
kafka๋ฐ์ดํฐ-์์ง๋์ด๋งsaint6692
ใป
5ใถๆๅ
0
63
2
- ๆช่งฃๆฑบ
avro plugin์ ์๋ณด์ด๋๊ฑฐ ๊ฐ์์
์๋ ํ์ธ์ ๊ฐ๋ฐ์๋ AvroConverter ๊ด๋ จ ๋ฌธ์ ๋๋ฆฝ๋๋ค.<p style="tex
kafka๋ฐ์ดํฐ-์์ง๋์ด๋งotteu
ใป
6ใถๆๅ
0
63
2
- ๆช่งฃๆฑบ
zookeeper๊ฐ ์คํ์ด ์๋์
echo $CONFLUENT_HOME์ด ์ ํํ ์์น์ธ๊ฒ ํ์ธํ๊ณ , zookeeper.properties์ zookeeper-server-start๊ฐ ์ ํํ ์์น์ธ ๊ฒ๋ ํ์ธํ์ต๋๋ค.๊ทธ๋ฌ๋ zookeeper-ser
kafka๋ฐ์ดํฐ-์์ง๋์ด๋งไฝๆ่ ใชใ
ใป
7ใถๆๅ
0
69
3
- ๆช่งฃๆฑบ
Debezium CDC Source Connector ์ด๋ฒคํธ ๋ฉ์์ง
์๋ ํ์ธ์, Debezium CDC Source Connector๊ฐ ์ด๋ฒคํธ๋ฅผ ๋ง๋ค๋ before, after ๊ฐ ์ค๋ช ํ์๋ ๋ถ๋ถ์์ ์ดํด๊ฐ ์๊ฐ๋ ๋ถ๋ถ์ด ์์ด์ ์ง๋ฌธ๋๋ฆฝ๋๋ค.<p style="text-align:
kafka๋ฐ์ดํฐ-์์ง๋์ด๋งhyojeongkim3073
ใป
7ใถๆๅ
0
79
2
- ๆช่งฃๆฑบ
์ฌ ์ง๋ฌธ! ๋ค๋ฅธ connector๊ฐ ๋์ผ ํ ํฝ ์ฌ์ฉ
๋ต๋ณ ๊ฐ์ฌํฉ๋๋ค.๋ต๋ณ์ ๋ณด๋ค ๋ณด๋ ๋ ์๋ก์ด ์ง๋ฌธ์ด ์๊ฒจ์ ๋ค์ ๋ฌธ์ ๋๋ฆฝ๋๋ค.debezi
kafka๋ฐ์ดํฐ-์์ง๋์ด๋งyeon9510302612
ใป
8ใถๆๅ
0
59
2
- ๆช่งฃๆฑบ
๋ฉ์์ง ๋ฐํ์ด ์ ๋ฉ๋๋ค.
kafka-console-producer๋ ์ฌ์ ํ ์ ๋์ํฉ๋๋ค. ๊ทธ๋ฐ๋ฐ kafka-avro-console-producer๋ก ๋ฉ์์ง๋ฅผ ๋ฐํํ๋ฉด, ์๋ฌด๋ฐ ์๋ฌ๋ฉ์์ง ์์ด, ๊ทธ๋ฅ ๋ฉ์์ง ๋ฐํ์ด ์ ๋ฉ๋๋ค. schema-re
kafka๋ฐ์ดํฐ-์์ง๋์ด๋งjaeheonna9271
ใป
8ใถๆๅ
0
69
2
- ๆช่งฃๆฑบ
๋๋น์ง์ ์คํ์ ๋ฆฌ์
1-1. ๋๋น์ง์๋ ์คํ์ ๋ฆฌ์ ์ด ๊ฐ๋ฅํ๊ฐ์?๊ทธ๋ ๊ฒ ๋๋ค๋ฉด๋ง์ฝ mysql ๋ก๊ทธ ๊ฒฝ๋ก์ ๋ก๊ทธ๋ค์ด ์์ ๊ณผ ๊ฐ
kafka๋ฐ์ดํฐ-์์ง๋์ด๋งyeon9510302612
ใป
8ใถๆๅ
0
81
2
- ๆช่งฃๆฑบ
mysql_jdbc_oc_sink_customers_02.json ์์ ์ค๋ฅ๋ฉ๋๋ค.
์ค๋๋ง์ ๊ฐ์๋ฅผ ์ ์ฒด๋ฅผ ๋ค์ ๋ฃ๊ณ ์์ต๋๋ค๋ง,์๋์ ๊ฐ์ ์๋ฌ์์ ๋ฒ์ด๋์ง ๋ชปํ๊ณ ์์ต๋๋ค.๋์ ์ฃผ์ธ์.
kafka๋ฐ์ดํฐ-์์ง๋์ด๋งanakin
ใป
8ใถๆๅ
0
60
3
- ๆช่งฃๆฑบ
io.debezium.connector.mysql.MySqlConnector ์ง๋ฌธ
snapshot mode์ ๊ถ๊ธํ ์ ์ด ์์ต๋๋ค.MySqlConnector ์ค๊ฐ์ ์๋ฌ๊ฐ ๋ฐ์ํ๋ฉด ์ปค๋ฅํฐ ๊ธฐ๋์ด ๋ฉ์ถ๋๋ฐ,<p style="text-ali
kafka๋ฐ์ดํฐ-์์ง๋์ด๋งddoddo
ใป
8ใถๆๅ
0
63
2
- ๆช่งฃๆฑบ
Debezium ์ด๋ฒคํธ ๋ฉ์์ง ๋ฐํ ์ ์ฑ๊ณต์ฌ๋ถ
์๋ ํ์ธ์ Debezium source connector ๋ถ๋ถ์ ๊ณต๋ถํ๋ค๊ฐ ๊ถ๊ธํ ๋ถ๋ถ์ด ์๊ฒจ์ ์ง๋ฌธ๋๋ฆฝ๋๋ค! <p style="text-alig
kafka๋ฐ์ดํฐ-์์ง๋์ด๋งtoryjee6084
ใป
9ใถๆๅ
0
78
2
- ๆช่งฃๆฑบ
connect ๊ตฌ๋ ์ค๋ฅ
์๋ ํ์ธ์.๊ฐ์์์ ์ค์ต์ ์ข ๋ฃํ ๋๋ ์ฒซ ๊ตฌ๋ ์์์ ๋ฐ๋๋ก ์์๋ก ์ข ๋ฃ๋ฅผ ํ๋ผ๊ณ ๋ง์์ ํ์ จ๋๋ฐ๊ทธ๋ฌ์ง
kafka๋ฐ์ดํฐ-์์ง๋์ด๋งddoddo
ใป
9ใถๆๅ
0
90
3
- ๆช่งฃๆฑบ
CDC Connect ํต์์์์ ์ํธํ ๊ด๋ จ ํ์ฌ ๋ฌธ์ ๋๋ฆฝ๋๋ค.
์๋ ํ์ธ์.์ธ๋ถ DB ์ connect ํ์ฌ CDC๋ฅผ ํตํด ๋ฐ์ดํฐ๋ฅผ ๊ฐ์ ธ ์ค๋ ๊ฒ์ ํ๊ณ ์์ต๋๋ค. ์ธ๋ถ์์ ๊ฐ์ ธ์ค๋ค ๋ณด๋ ๋ฐ์ดํฐ๋ฅผ ๋ณดํธ ํ๊ณ ์ถ๋ค๋ ์๊ฐ
kafka๋ฐ์ดํฐ-์์ง๋์ด๋งotteu
ใป
10ใถๆๅ
0
110
2
- ๆช่งฃๆฑบ
GCSSinkconnector
์๋ ํ์ธ์,๊ฐ์๋ฅผ ๋ฃ๊ธฐ ์ ์ ๋ช ๊ฐ์ง ์ฌ์ญ๊ณ ์ ํฉ๋๋ค.self-host๋ก kafka-connect๋ฅผ ์ด์
kafka๋ฐ์ดํฐ-์์ง๋์ด๋งnyeongna
ใป
10ใถๆๅ
0
58
1
- ๆช่งฃๆฑบ
debezium source connector์์ `poll.interval.ms` ํ๋ผ๋ฏธํฐ
๊ฐ์๋ฅผ ๋ค์ผ๋ฉด์ ํท๊ฐ๋ฆฌ๋ ๋ถ๋ถ์ด ์๋๋ฐ์. debezium source connector๋ฑ๋ก์ ์ค์ ํ๋ poll.interval.ms ํ๋ผ๋ฏธํฐ๋ debezium source connector๊ฐ
kafka๋ฐ์ดํฐ-์์ง๋์ด๋งhanjn28429394
ใป
0
137
2
- ่งฃๆฑบ
์๋ฌธ์๋ต: JDBC Sink Connector๊ฐ PostgreSQL์ Schema๋ฅผ ๋ฐ๋ผ๋ณด์ง ์์ต๋๋ค.
2025-02-24 ์ถ๊ฐ) ํด๋น ๋ฌธ์ ๋ psql session ๋ก๊ทธ์ธ ์๋์์ database๋ง ์ ์ ๊ทผํ๋ฉด ๋ฌธ์ ์์ต๋๋ค. ๊ฐ์๋๋ก ๋ฐ๋ผ๊ฐ์๋ฉด ๋ฉ๋๋ค.psql -h localhost -U connect_dev -d ${database_
kafka๋ฐ์ดํฐ-์์ง๋์ด๋งlogt
ใป
0
204
1
- ่งฃๆฑบ
table.name.format์ ๊ดํ์ฌ..
์๋ ํ์ธ์ ์ ์๋. ๊ฐ์ ์ ๋ณด๊ณ ์์ต๋๋ค.JDBC Sink Connector์ ๋ฐ์ดํฐ๋ฒ ์ด์ค ์คํค๋ง ์ค์ ๋ฌธ์ ๊ฐ ์๋ค์. ์ฐพ์๋ณด๋ JDBC Sink Connector์ ๋ด๋ถ์ ์ธ ๋ฌธ์ ๊ฐ์ต๋๋ค... ๊ตฌ๊ธ๋ง์ ํด๋ณด๋ table.name.form
kafka๋ฐ์ดํฐ-์์ง๋์ด๋งlogt
ใป
0
189
2
- ๆช่งฃๆฑบ
binlog์ offset ๊ด๋ จ ์ถ๊ฐ ์ง๋ฌธ๋๋ฆฝ๋๋ค
์๋ ํ์ธ์~ ๊ฐ์๋ฅผ ๋ฃ๋ค๊ฐ binlog๊ด๋ จ ๊ถ๊ธํ ์ ์ด ์๊ฒจ์ ์ง๋ฌธ๋๋ฆฝ๋๋ค!ํด๋น ์ปค๋ฅํธ์ offset์ ๋ณด์ ๋ด๊ธด binlogํ์ผ์ด ๋ง์ฝ ์ญ์ ๋๋ค๋ฉด ๊ธฐ๋ ์ค์ ์ค๋ฅ๊ฐ ๋ฐ์ํ๋ค๊ณ ๋ง์์ ์ฃผ์ จ๋๋ฐ, ๊ทธ๋ผ ๋ง์ฝ binlog ํ์ผ์ด ์ปค์ ธ์ ๋ค์ ํ
kafka๋ฐ์ดํฐ-์์ง๋์ด๋งrlaxogud940418
ใป
0
143
1
- ๆช่งฃๆฑบ
Debezium cdc source for MSSQL-Server [๋ฑ๋ก์ค๋ฅ]
MSSQL-Server ์ฉ๋๋ก Debezium cdc source๋ฅผ ๋ฑ๋กํด์ ์ฌ์ฉํ๊ณ ์ถ์ต๋๋ค๋ง, ์๋์ ๊ฐ์ด config ๋ฑ๋ก ์{ "name": "mssql_cdc_oc_source_01",
kafka๋ฐ์ดํฐ-์์ง๋์ด๋งanakin
ใป
0
183
2
- ๆช่งฃๆฑบ
http http://localhost:8083/connector-plugins ์ ํ๋ฌ๊ทธ์ธ์ด ๋ณด์ด์ง ์์ต๋๋ค.
connect๋ฅผ ์ฌ๊ฐ๋ํด๋ ๋ณด์ด์ง๊ฐ ์๋ค์..๊ฒฝ๋ก ๋ฌธ์ ์ผ๊น์? ์๋์ ๊ฐ์ด ๊ฒฐ๊ณผ๊ฐ ๋์ต๋๋ค.(cdc_source_connector/, jdbc_connector/ ์์น์ jar ํ์ผ๋ค์ ๋ชจ๋ ์์ต๋๋ค.)<
kafka๋ฐ์ดํฐ-์์ง๋์ด๋งcksohn6655
ใป
0
182
2

