Documentation
¶
Overview ¶
nolint: lll
Package kafka exports types, functions, subpackages for provisioning kafka resources.// A Pulumi package for creating and managing Kafka.
> This provider is a derived work of the [Terraform Provider](https://github.com/Mongey/terraform-provider-kafka) > distributed under [MIT](https://mit-license.org/). If you encounter a bug or missing feature, > first check the [`pulumi/pulumi-kafka` repo](https://github.com/pulumi/pulumi-kafka/issues); however, if that doesn't turn up anything, > please consult the source [`Mongey/terraform-provider-kafka` repo](https://github.com/Mongey/terraform-provider-kafka/issues).
nolint: lll
nolint: lll
nolint: lll
nolint: lll
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Acl ¶
type Acl struct {
pulumi.CustomResourceState
AclHost pulumi.StringOutput `pulumi:"aclHost"`
AclOperation pulumi.StringOutput `pulumi:"aclOperation"`
AclPermissionType pulumi.StringOutput `pulumi:"aclPermissionType"`
AclPrincipal pulumi.StringOutput `pulumi:"aclPrincipal"`
// The name of the resouce
AclResourceName pulumi.StringOutput `pulumi:"aclResourceName"`
AclResourceType pulumi.StringOutput `pulumi:"aclResourceType"`
ResourcePatternTypeFilter pulumi.StringPtrOutput `pulumi:"resourcePatternTypeFilter"`
}
func GetAcl ¶
func GetAcl(ctx *pulumi.Context, name string, id pulumi.IDInput, state *AclState, opts ...pulumi.ResourceOption) (*Acl, error)
GetAcl gets an existing Acl resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).
type AclArgs ¶
type AclArgs struct {
AclHost pulumi.StringInput
AclOperation pulumi.StringInput
AclPermissionType pulumi.StringInput
AclPrincipal pulumi.StringInput
// The name of the resouce
AclResourceName pulumi.StringInput
AclResourceType pulumi.StringInput
ResourcePatternTypeFilter pulumi.StringPtrInput
}
The set of arguments for constructing a Acl resource.
func (AclArgs) ElementType ¶ added in v1.5.0
type AclState ¶
type AclState struct {
AclHost pulumi.StringPtrInput
AclOperation pulumi.StringPtrInput
AclPermissionType pulumi.StringPtrInput
AclPrincipal pulumi.StringPtrInput
// The name of the resouce
AclResourceName pulumi.StringPtrInput
AclResourceType pulumi.StringPtrInput
ResourcePatternTypeFilter pulumi.StringPtrInput
}
func (AclState) ElementType ¶ added in v1.5.0
type Provider ¶ added in v1.5.0
type Provider struct {
pulumi.ProviderResourceState
}
The provider type for the kafka package. By default, resources use package-wide configuration settings, however an explicit `Provider` instance may be created and passed during resource construction to achieve fine-grained programmatic control over provider settings. See the [documentation](https://www.pulumi.com/docs/reference/programming-model/#providers) for more information.
> This content is derived from https://github.com/Mongey/terraform-provider-kafka/blob/master/website/docs/index.html.markdown.
func NewProvider ¶ added in v1.5.0
func NewProvider(ctx *pulumi.Context, name string, args *ProviderArgs, opts ...pulumi.ResourceOption) (*Provider, error)
NewProvider registers a new resource with the given unique name, arguments, and options.
type ProviderArgs ¶ added in v1.5.0
type ProviderArgs struct {
// A list of kafka brokers
BootstrapServers pulumi.StringArrayInput
// CA certificate file to validate the server's certificate.
CaCert pulumi.StringPtrInput
// Path to a CA certificate file to validate the server's certificate.
CaCertFile pulumi.StringPtrInput
// The client certificate.
ClientCert pulumi.StringPtrInput
// Path to a file containing the client certificate.
ClientCertFile pulumi.StringPtrInput
// The private key that the certificate was issued for.
ClientKey pulumi.StringPtrInput
// Path to a file containing the private key that the certificate was issued for.
ClientKeyFile pulumi.StringPtrInput
// SASL mechanism, can be plain, scram-sha512, scram-sha256
SaslMechanism pulumi.StringPtrInput
// Password for SASL authentication.
SaslPassword pulumi.StringPtrInput
// Username for SASL authentication.
SaslUsername pulumi.StringPtrInput
// Set this to true only if the target Kafka server is an insecure development instance.
SkipTlsVerify pulumi.BoolPtrInput
// Timeout in seconds
Timeout pulumi.IntPtrInput
// Enable communication with the Kafka Cluster over TLS.
TlsEnabled pulumi.BoolPtrInput
}
The set of arguments for constructing a Provider resource.
func (ProviderArgs) ElementType ¶ added in v1.5.0
func (ProviderArgs) ElementType() reflect.Type
type Topic ¶
type Topic struct {
pulumi.CustomResourceState
// A map of string k/v attributes.
Config pulumi.MapOutput `pulumi:"config"`
// The name of the topic.
Name pulumi.StringOutput `pulumi:"name"`
// Number of partitions.
Partitions pulumi.IntOutput `pulumi:"partitions"`
// Number of replicas.
ReplicationFactor pulumi.IntOutput `pulumi:"replicationFactor"`
}
func GetTopic ¶
func GetTopic(ctx *pulumi.Context, name string, id pulumi.IDInput, state *TopicState, opts ...pulumi.ResourceOption) (*Topic, error)
GetTopic gets an existing Topic resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).
type TopicArgs ¶
type TopicArgs struct {
// A map of string k/v attributes.
Config pulumi.MapInput
// The name of the topic.
Name pulumi.StringPtrInput
// Number of partitions.
Partitions pulumi.IntInput
// Number of replicas.
ReplicationFactor pulumi.IntInput
}
The set of arguments for constructing a Topic resource.
func (TopicArgs) ElementType ¶ added in v1.5.0
type TopicState ¶
type TopicState struct {
// A map of string k/v attributes.
Config pulumi.MapInput
// The name of the topic.
Name pulumi.StringPtrInput
// Number of partitions.
Partitions pulumi.IntPtrInput
// Number of replicas.
ReplicationFactor pulumi.IntPtrInput
}
func (TopicState) ElementType ¶ added in v1.5.0
func (TopicState) ElementType() reflect.Type
Source Files