Introduce a callback for rewriting broker addresses

Use librdkafka's new DNS resolution callback to expose a rust-rdkafka callback for rewriting broker addresses. This allows tunneling of a Kafka connection over SSH or PrivateLink, by rewriting the broker addresses returned during bootstrapping to addresses that will route through the tunnel.
fede1024 · Nov 6, 2022 · 24b071c · 24b071c
1 parent b71acb0
commit 24b071c
Show file tree

Hide file tree

Showing 5 changed files with 213 additions and 175 deletions.
diff --git a/.gitmodules b/.gitmodules
@@ -1,3 +1,3 @@
 [submodule "rdkafka-sys/librdkafka"]
 	path = rdkafka-sys/librdkafka
-	url = https://github.com/edenhill/librdkafka
+	url = https://github.com/MaterializeInc/librdkafka
diff --git a/rdkafka-sys/librdkafka b/rdkafka-sys/librdkafka
+1 −0		CONFIGURATION.md
+ −		examples/misc
+ −		examples/openssl_engine_example_cpp
+21 −8		src/rdaddr.c
+14 −7		src/rdaddr.h
+22 −0		src/rdkafka.h
+5 −4		src/rdkafka_broker.c
+12 −0		src/rdkafka_conf.c
+7 −0		src/rdkafka_conf.h
+117 −0		tests/0135-resolve_cb.c
+1 −0		tests/CMakeLists.txt
+2 −1		tests/test.c
+1 −0		win32/tests/tests.vcxproj