MCPcopy Index your code
hub / github.com/a0x8o/kafka

github.com/a0x8o/kafka @main

Chat with this repo
repository ↗ · DeepWiki ↗ · + Follow
214,444 symbols 1,183,876 edges 16,900 files 44,521 documented · 21%
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

WorkerStatusTracker (Interface)
Tracks the status of a Trogdor worker. [93 implementers]
tools/src/main/java/org/apache/kafka/trogdor/task/WorkerStatusTracker.java
HiveValueWriter (Interface)
The writer is used to abstract writing of row values or values embedded into row (for example, elements of List complex [246 …
contrib/storage-hive/core/src/main/java/org/apache/drill/exec/store/hive/writers/HiveValueWriter.java
FnService (Interface)
An interface sharing common behavior with services used during execution of user Fns. [1351 implementers]
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/FnService.java
GroupAlsoByWindowsDoFnFactory (Interface)
A factory of GroupAlsoByWindowsDoFn so that the various properties can provide the appropriate windowing strateg [6 implementers]
runners/core-java/src/test/java/org/apache/beam/runners/core/GroupAlsoByWindowsProperties.java
Closer (Interface)
A function that knows how to clean up after a resource. [1335 implementers]
runners/reference/java/src/main/java/org/apache/beam/runners/reference/CloseableResource.java
OldPerKeyCombineFnRunner (Interface)
An interface that runs a PerKeyCombineFn with unified APIs using OldDoFn.ProcessContext. [80 implementers]
runners/flink/runner/src/main/java/org/apache/beam/runners/flink/OldPerKeyCombineFnRunner.java
ApexStreamTuple (Interface)
The common interface for all objects transmitted through streams. @param The actual payload type. [120 implementers]
runners/apex/src/main/java/org/apache/beam/runners/apex/translation/utils/ApexStreamTuple.java
TransformPayloadTranslatorRegistrar (Interface)
A registrar of TransformPayloadTranslator. [23 implementers]
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/TransformPayloadTranslatorRegistrar.java

Core symbols most depended-on inside this repo

asList
called by 6425
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/View.java
format
called by 5740
exec/vector/src/main/java/org/apache/drill/exec/record/metadata/ColumnMetadata.java
build
called by 5585
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkLauncher.java
equals
called by 5510
streams/src/main/java/org/apache/kafka/streams/TaskMetadata.java
add
called by 5347
exec/java-exec/src/main/java/org/apache/drill/exec/expr/DrillAggFunc.java
get
called by 4749
clients/src/main/java/org/apache/kafka/common/cache/Cache.java
put
called by 4523
streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java
put
called by 4332
clients/src/main/java/org/apache/kafka/common/cache/Cache.java

Shape

Method 174,464
Class 26,890
Function 8,561
Interface 2,490
Struct 1,045
Enum 716
Route 195
TypeAlias 74
FuncType 9

Languages

Java83%
Python8%
Go6%
C++3%
C1%
TypeScript1%

Modules by API surface

protocol/src/main/java/org/apache/drill/exec/proto/UserBitShared.java2,230 symbols
sdks/go/pkg/beam/core/runtime/exec/optimized/inputs.go2,029 symbols
sdks/go/pkg/beam/core/runtime/exec/optimized/emitters.go2,028 symbols
contrib/native/client/src/protobuf/User.pb.h1,285 symbols
sdks/go/pkg/beam/model/pipeline_v1/beam_runner_api.pb.go1,048 symbols
sdks/go/pkg/beam/model/fnexecution_v1/beam_fn_api.pb.go929 symbols
protocol/src/main/java/org/apache/drill/exec/proto/BitControl.java878 symbols
contrib/native/client/src/protobuf/UserBitShared.pb.h826 symbols
protocol/src/main/java/org/apache/drill/exec/proto/SchemaUserProtos.java714 symbols
exec/java-exec/src/main/java/org/apache/drill/exec/expr/fn/impl/StatisticsAggrFunctions.java664 symbols
exec/java-exec/src/main/resources/rest/static/js/d3.v3.js552 symbols
sdks/go/pkg/beam/core/runtime/exec/optimized/decoders.go529 symbols

Datastores touched

(mongodb)Database · 1 repos
(mysql)Database · 1 repos
usersDatabase · 1 repos
mainDatabase · 1 repos
somedbDatabase · 1 repos
mydbDatabase · 1 repos

For agents

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

⬇ download graph artifact