ΠΠ΄Π°ΠΏΡΠ΅Ρ Π΄Π»Ρ Π²Π·Π°ΠΈΠΌΠΎΠ΄Π΅ΠΉΡΡΠ²ΠΈΡ Ρ kafka ΡΠ΅ΡΠ΅Π· Confluent REST Proxy.
ΠΠΎΠΊΡΠΌΠ΅Π½ΡΠ°ΡΠΈΡ API, Π½Π° ΠΊΠΎΡΠΎΡΠΎΠΉ ΠΎΡΠ½ΠΎΠ²Π°Π½ Π΄Π°Π½Π½ΡΠΉ ΠΌΠΎΠ΄ΡΠ»Ρ
ΠΡΡΡΡΠΎ ΠΏΠΎΡΠΌΠΎΡΡΠ΅ΡΡ ΡΠ΅ΠΊΡΡ ΠΌΠΎΠ΄ΡΠ»Ρ
ΠΡΡΠΏΠΏΠ° Π² ΡΠ΅Π»Π΅Π³ΡΠ°ΠΌΠΌ.
ΠΡΠ½ΠΎΠ²Π½ΡΠ΅ Π²ΠΎΠ·ΠΌΠΎΠΆΠ½ΠΎΡΡΠΈ Π°Π΄Π°ΠΏΡΠ΅ΡΠ°:
- ΠΡΠΏΡΠ°Π²ΠΊΠ° ΡΠΎΠΎΠ±ΡΠ΅Π½ΠΈΠΉ Π² ΡΠΎΠΏΠΈΠΊΠΈ kafka
- ΠΠΎΠ»ΡΡΠ΅Π½ΠΈΠ΅ ΡΠΎΠΎΠ±ΡΠ΅Π½ΠΈΠΉ ΠΈΠ· ΡΠΎΠΏΠΈΠΊΠ° kafka
- ΠΠΎΠ³ΠΈΡΠΎΠ²Π°Π½ΠΈΠ΅ ΠΎΠΏΠ΅ΡΠ°ΡΠΈΠΉ Π² ΡΠ°ΠΌΠΊΠ°Ρ ΠΎΠ΄Π½ΠΎΠ³ΠΎ ΠΊΠΎΠ½ΡΠ΅ΠΊΡΡΠ°(ΠΎΡΠΏΡΠ°Π²ΠΈΡΠ΅Π»Ρ ΠΈΠ»ΠΈ ΠΏΠΎΠ»ΡΡΠ°ΡΠ΅Π»Ρ)
- ΠΠ»Π°ΡΡΠΎΡΠΌΠ° 8.3.10 ΠΈ Π²ΡΡΠ΅.
- "ΠΠΎΠ½Π½Π΅ΠΊΡΠΎΡ: ΡΠ΄ΠΎΠ±Π½ΡΠΉ HTTP-ΠΊΠ»ΠΈΠ΅Π½Ρ Π΄Π»Ρ 1Π‘:ΠΡΠ΅Π΄ΠΏΡΠΈΡΡΠΈΠ΅ 8" https://github.com/vbondarevsky/Connector
Π£ΡΡΠ°Π½ΠΎΠ²ΠΈΡΠ΅ ΡΠ΅ΡΠ΅Π· ΠΏΠΎΡΡΠ°Π²ΠΊΡ ΠΌΠΎΠ΄ΡΠ»Ρ ΠΊ ΡΠ΅Π±Π΅ Π² ΠΊΠΎΠ½ΡΠΈΠ³ΡΡΠ°ΡΠΈΡ(Π΄Π»Ρ Π²ΠΎΠ·ΠΌΠΎΠΆΠ½ΠΎΡΡΠΈ Π΄Π°Π»ΡΠ½Π΅ΠΉΡΠ΅Π³ΠΎ ΠΎΠ±Π½ΠΎΠ²Π»Π΅Π½ΠΈΡ).
ΠΠ°ΠΊ ΠΎΡΠΏΡΠ°Π²ΠΈΡΡ ΡΠΎΠΎΠ±ΡΠ΅Π½ΠΈΠ΅ "Hello world!" Π² ΡΠΎΠΏΠΈΠΊ: "1c.topic":
Π‘ΠΎΠ΅Π΄ΠΈΠ½Π΅Π½ΠΈΠ΅ΠΠ°ΡΠΊΠ° = ΠΠ°ΡΠΊΠ°.ΠΠΎΠ²ΠΎΠ΅ΠΠΏΠΈΡΠ°Π½ΠΈΠ΅Π‘ΠΎΠ΅Π΄ΠΈΠ½Π΅Π½ΠΈΡ("http://localhost:8082", "json");
ΠΡΠΏΡΠ°Π²ΠΈΡΠ΅Π»Ρ = ΠΠ°ΡΠΊΠ°.ΠΠΎΠ²ΡΠΉΠΡΠΏΡΠ°Π²ΠΈΡΠ΅Π»Ρ(Π‘ΠΎΠ΅Π΄ΠΈΠ½Π΅Π½ΠΈΠ΅ΠΠ°ΡΠΊΠ°);
ΠΠ°ΡΠΊΠ°.ΠΠΎΠ±Π°Π²ΠΈΡΡΠ‘ΠΎΠΎΠ±ΡΠ΅Π½ΠΈΠ΅(ΠΡΠΏΡΠ°Π²ΠΈΡΠ΅Π»Ρ, "Hello world!", "1c.topic");
ΠΠ°ΡΠΊΠ°.ΠΡΠΏΡΠ°Π²ΠΈΡΡΠ‘ΠΎΠΎΠ±ΡΠ΅Π½ΠΈΡ(ΠΡΠΏΡΠ°Π²ΠΈΡΠ΅Π»Ρ); ΠΠ΄Π΅ Π·Π°Π»ΠΎΠ³ΠΈΡΠΎΠ²Π°Π½Ρ ΠΎΠΏΠ΅ΡΠ°ΡΠΈΠΈ:
Π’Π΅ΠΊΡΡΠΠΎΠ³Π° = Π‘ΡΡΠ‘ΠΎΠ΅Π΄ΠΈΠ½ΠΈΡΡ(ΠΡΠΏΡΠ°Π²ΠΈΡΠ΅Π»Ρ.ΠΠΏΠΈΡΠ°Π½ΠΈΠ΅Π‘ΠΎΠ΅Π΄ΠΈΠ½Π΅Π½ΠΈΡ.Π Π΅Π·ΡΠ»ΡΡΠ°ΡΠ‘ΠΎΠ΅Π΄ΠΈΠ½Π΅Π½ΠΈΡ.ΠΡΡΠΎΡΠΈΡΠΠΏΠ΅ΡΠ°ΡΠΈΠΉ, Π‘ΠΈΠΌΠ²ΠΎΠ»Ρ.ΠΠ‘);ΠΠ°ΠΊ ΠΏΡΠΎΡΠΈΡΠ°ΡΡ ΡΠΎΠΎΠ±ΡΠ΅Π½ΠΈΡ ΠΈΠ· ΡΠΎΠΏΠΈΠΊΠ°: "1Ρ.topic":
Π‘ΠΎΠ΅Π΄ΠΈΠ½Π΅Π½ΠΈΠ΅ΠΠ°ΡΠΊΠ° = ΠΠ°ΡΠΊΠ°.ΠΠΎΠ²ΠΎΠ΅ΠΠΏΠΈΡΠ°Π½ΠΈΠ΅Π‘ΠΎΠ΅Π΄ΠΈΠ½Π΅Π½ΠΈΡ("http://localhost:8082", "json");
ΠΠΎΠ΄ΠΏΠΈΡΡΠΈΠΊ = ΠΠ°ΡΠΊΠ°.ΠΠΎΠ²ΡΠΉΠΠΎΠ΄ΠΏΠΈΡΡΠΈΠΊ(Π‘ΠΎΠ΅Π΄ΠΈΠ½Π΅Π½ΠΈΠ΅ΠΠ°ΡΠΊΠ°, "ConsumerGroup1C", , ΠΡΡΠΈΠ½Π°, 100);
ΠΠ°ΡΠΊΠ°.ΠΠ°ΡΠ΅Π³ΠΈΡΡΡΠΈΡΠΎΠ²Π°ΡΡΠΠΎΠ΄ΠΏΠΈΡΡΠΈΠΊΠ°(ΠΠΎΠ΄ΠΏΠΈΡΡΠΈΠΊ);
ΠΠ°ΡΠΊΠ°.ΠΠΎΠ΄ΠΏΠΈΡΠ°ΡΡΡΡ(ΠΠΎΠ΄ΠΏΠΈΡΡΠΈΠΊ, ΠΠ±ΡΠ΅ΠΊΡ.topic);
Π‘ΠΎΠΎΠ±ΡΠ΅Π½ΠΈΡ = ΠΠ°ΡΠΊΠ°.ΠΠΎΠ»ΡΡΠΈΡΡΠ‘ΠΎΠΎΠ±ΡΠ΅Π½ΠΈΡ(ΠΠΎΠ΄ΠΏΠΈΡΡΠΈΠΊ);
ΠΠ»Ρ ΠΊΠ°ΠΆΠ΄ΠΎΠ³ΠΎ Π‘ΠΎΠΎΠ±ΡΠ΅Π½ΠΈΠ΅ ΠΈΠ· Π‘ΠΎΠΎΠ±ΡΠ΅Π½ΠΈΡ Π¦ΠΈΠΊΠ»
Π’Π΅Π»ΠΎΠ‘ΠΎΠΎΠ±ΡΠ΅Π½ΠΈΡ = Π‘ΠΎΠΎΠ±ΡΠ΅Π½ΠΈΠ΅.ΠΠΎΠ»ΡΡΠΈΡΡ("value");
ΠΠΎΠ½Π΅ΡΠ¦ΠΈΠΊΠ»Π°;
ΠΠ°ΡΠΊΠ°.Π£Π΄Π°Π»ΠΈΡΡΠΠΎΠ΄ΠΈΡΡΠΈΠΊΠ°(ΠΠΎΠ΄ΠΏΠΈΡΡΠΈΠΊ);