Module materialize.mzcompose.services.kgen
Expand source code Browse git
# Copyright Materialize, Inc. and contributors. All rights reserved.
#
# Use of this software is governed by the Business Source License
# included in the LICENSE file at the root of this repository.
#
# As of the Change Date specified in that file, in accordance with
# the Business Source License, use of this software will be governed
# by the Apache License, Version 2.0.
from materialize.mzcompose.service import (
Service,
)
class Kgen(Service):
def __init__(
self,
name: str = "kgen",
mzbuild: str = "kgen",
depends_on: list[str] = ["kafka"],
) -> None:
entrypoint = [
"kgen",
"--bootstrap-server=kafka:9092",
]
if "schema-registry" in depends_on:
entrypoint.append("--schema-registry-url=http://schema-registry:8081")
super().__init__(
name=name,
config={
"mzbuild": mzbuild,
"depends_on": depends_on,
"entrypoint": entrypoint,
},
)
Classes
class Kgen (name: str = 'kgen', mzbuild: str = 'kgen', depends_on: list[str] = ['kafka'])
-
A Docker Compose service in a
Composition
.Attributes
name
- The name of the service.
config
- The definition of the service.
Expand source code Browse git
class Kgen(Service): def __init__( self, name: str = "kgen", mzbuild: str = "kgen", depends_on: list[str] = ["kafka"], ) -> None: entrypoint = [ "kgen", "--bootstrap-server=kafka:9092", ] if "schema-registry" in depends_on: entrypoint.append("--schema-registry-url=http://schema-registry:8081") super().__init__( name=name, config={ "mzbuild": mzbuild, "depends_on": depends_on, "entrypoint": entrypoint, }, )
Ancestors