hub / github.com/dajudge/kafkaproxy

github.com/dajudge/kafkaproxy @main

Chat with this repo

repository ↗ · DeepWiki ↗ · + Follow

409 symbols 903 edges 72 files 0 documented · 0%

What it actually does AI analysis from the code graph — generated when you open this

loading…

Extension points exported contracts — how you extend this code

Test (Interface)

(no doc) [6 implementers]

itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/Startup.java

ResponseRewriter (Interface)

(no doc) [6 implementers]

core/src/main/java/com/dajudge/kafkaproxy/protocol/rewrite/ResponseRewriter.java

Sink (Interface)

(no doc) [2 implementers]

itests/src/main/clients/dotnet/Sink.cs

ServerSecurity (Interface)

(no doc) [4 implementers]

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ServerSecurity.java

ThrowingFunction (Interface)

(no doc) [1 implementers]

itests/src/test/java/com/dajudge/kafkaproxy/itest/BaseIntegrationTest.java

ClientSecurity (Interface)

(no doc) [4 implementers]

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ClientSecurity.java

Poll (Interface)

(no doc) [1 implementers]

itests/src/main/clients/dotnet/Poll.cs

CommunicationSetup (Interface)

(no doc) [4 implementers]

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/CommunicationSetup.java

Core symbols most depended-on inside this repo

getProxy

called by 13

core/src/main/java/com/dajudge/kafkaproxy/BrokerMapping.java

optionalString

called by 10

core/src/main/java/com/dajudge/kafkaproxy/config/Environment.java

apply

called by 8

itests/src/test/java/com/dajudge/kafkaproxy/itest/BaseIntegrationTest.java

CurrentTimeMillis

called by 7

itests/src/main/clients/dotnet/TimeUtils.cs

getKeyStorePassword

called by 6

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ServerSecurity.java

add

called by 6

core/src/main/java/com/dajudge/kafkaproxy/protocol/KafkaRequestStore.java

parse

called by 6

core/src/main/java/com/dajudge/kafkaproxy/config/ConfigSource.java

create

called by 5

core/src/main/java/com/dajudge/kafkaproxy/KafkaProxyApplication.java

Shape

Method 325

Class 71

Interface 13

Languages

Java89%

C#11%

Modules by API surface

itests/src/main/clients/java/src/main/java/com/dajudge/kafkaproxy/tests/MultiClientTest.java28 symbols

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslServerSecurity.java14 symbols

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/SslClientSecurity.java13 symbols

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/ServerSecurity.java13 symbols

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextServerSecurity.java13 symbols

itests/src/test/java/com/dajudge/kafkaproxy/itest/BaseIntegrationTest.java12 symbols

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/cluster/KafkaClusterBuilder.java12 symbols

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/comm/PlaintextClientSecurity.java11 symbols

itests/src/main/clients/dotnet/TestRunner.cs10 symbols

core/src/test/java/com/dajudge/kafkaproxy/roundtrip/RoundtripTest.java10 symbols

core/src/main/java/com/dajudge/kafkaproxy/config/BrokerConfigSource.java10 symbols

core/src/main/java/com/dajudge/kafkaproxy/protocol/KafkaMessage.java9 symbols

For agents

$ claude mcp add kafkaproxy \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact