Dagger
Search

kafka

No long description provided.

Installation

dagger install github.com/sagikazarmark/daggerverse/kafka@93d0e7724f12e78d6f9c3917d4e1f52812e9b5c1

Entrypoint

Return Type
Kafka
Example
func (m *myModule) example() *Kafka  {
	return dag.
			Kafka()
}
@function
def example() -> dag.Kafka:
	return (
		dag.kafka()
	)
@func()
example(): Kafka {
	return dag
		.kafka()
}

Types

Kafka 🔗

withVersion() 🔗

Specify which version of Kafka to use.

Return Type
KafkaContainer !
Arguments
NameTypeDefault ValueDescription
versionStringKind !-No description provided
Example
Function Kafka.withVersion is not accessible from the kafka module
func (m *myModule) example(version )   {
	return dag.
			Kafka().
			WithVersion(version)
}
@function
def example(version: ) -> :
	return (
		dag.kafka()
		.with_version(version)
	)
@func()
example(version: ):  {
	return dag
		.kafka()
		.withVersion(version)
}

withImageRef() 🔗

Specify a custom image reference in “repository:tag” format.

Note: this module expects an image compatible with bitnami/kafka.

Return Type
KafkaContainer !
Arguments
NameTypeDefault ValueDescription
refStringKind !-No description provided
Example
Function Kafka.withImageRef is not accessible from the kafka module
func (m *myModule) example(ref )   {
	return dag.
			Kafka().
			WithImageRef(ref)
}
@function
def example(ref: ) -> :
	return (
		dag.kafka()
		.with_image_ref(ref)
	)
@func()
example(ref: ):  {
	return dag
		.kafka()
		.withImageRef(ref)
}

withContainer() 🔗

Specify a custom container.

Note: this module expects an image compatible with bitnami/kafka.

Return Type
KafkaContainer !
Arguments
NameTypeDefault ValueDescription
ctrContainer !-No description provided
Example
Function Kafka.withContainer is not accessible from the kafka module
func (m *myModule) example(ctr )   {
	return dag.
			Kafka().
			WithContainer(ctr)
}
@function
def example(ctr: ) -> :
	return (
		dag.kafka()
		.with_container(ctr)
	)
@func()
example(ctr: ):  {
	return dag
		.kafka()
		.withContainer(ctr)
}

container() 🔗

Return the default container.

Return Type
Container !
Example
Function Kafka.container is not accessible from the kafka module
func (m *myModule) example()   {
	return dag.
			Kafka().
			Container()
}
@function
def example() -> :
	return (
		dag.kafka()
		.container()
	)
@func()
example():  {
	return dag
		.kafka()
		.container()
}

service() 🔗

Launch a Kafka service using the default container.

Return Type
Service !
Example
Function Kafka.service is not accessible from the kafka module
func (m *myModule) example()   {
	return dag.
			Kafka().
			Service()
}
@function
def example() -> :
	return (
		dag.kafka()
		.service()
	)
@func()
example():  {
	return dag
		.kafka()
		.service()
}

KafkaContainer 🔗

ctr() 🔗

Return Type
Container !
Example
Function KafkaKafkaContainer.Ctr is not accessible from the kafka module
Function KafkaKafkaContainer.Ctr is not accessible from the kafka module
Function KafkaKafkaContainer.Ctr is not accessible from the kafka module
Function KafkaKafkaContainer.Ctr is not accessible from the kafka module

container() 🔗

Return the default container.

Return Type
Container !
Example
Function KafkaKafkaContainer.container is not accessible from the kafka module
Function KafkaKafkaContainer.container is not accessible from the kafka module
Function KafkaKafkaContainer.container is not accessible from the kafka module
Function KafkaKafkaContainer.container is not accessible from the kafka module

service() 🔗

Launch a Kafka service using the default container.

Return Type
Service !
Example
Function KafkaKafkaContainer.service is not accessible from the kafka module
Function KafkaKafkaContainer.service is not accessible from the kafka module
Function KafkaKafkaContainer.service is not accessible from the kafka module
Function KafkaKafkaContainer.service is not accessible from the kafka module