extmsk

type KafkaAttackState struct {
	BrokerID         string
	BrokerARN        string
	ClusterARN       string
	ClusterName      string
	Account          string
	Region           string
	DiscoveredByRole *string
}

type MskApi interface {
	RebootBroker(ctx context.Context, params *kafka.RebootBrokerInput, optFns ...func(*kafka.Options)) (*kafka.RebootBrokerOutput, error)
	kafka.ListClustersV2APIClient
	kafka.ListNodesAPIClient
}