MCPcopy
hub / github.com/apache/kafka / Handler

Interface Handler

shell/src/main/java/org/apache/kafka/shell/command/Commands.java:73–79  ·  view source on GitHub ↗

Command handler objects are instantiated with specific arguments to execute commands.

Source from the content-addressed store, hash-verified

71 * execute commands.
72 */
73 public interface Handler {
74 void run(
75 Optional<InteractiveShell> shell,
76 PrintWriter writer,
77 MetadataShellState state
78 ) throws Exception;
79 }
80
81 /**
82 * An object which describes a type of command handler. This includes

Implementers 15

ConfigCommandIntegrationTesttools/src/test/java/org/apache/kafka/t
ReplicationQuotasTestRigtools/src/test/java/org/apache/kafka/t
Experimenttools/src/test/java/org/apache/kafka/t
HttpReportertools/src/main/java/org/apache/kafka/t
VerifiableConsumertools/src/main/java/org/apache/kafka/t
PrintVersionAndExitActiontools/src/main/java/org/apache/kafka/t
LeaderElectionCommandtools/src/main/java/org/apache/kafka/t
ShareConsumerPerformancetools/src/main/java/org/apache/kafka/t
VerifiableProducertools/src/main/java/org/apache/kafka/t
ConsumerPerformancetools/src/main/java/org/apache/kafka/t
VerifiableShareConsumertools/src/main/java/org/apache/kafka/t
ClientCompatibilityTesttools/src/main/java/org/apache/kafka/t

Calls

no outgoing calls

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…