Aiven

Pulumi Official
Package maintained by Pulumi
v5.2.0 published on Wednesday, Jul 20, 2022 by Pulumi

getKafka

The Kafka data source provides information about the existing Aiven Kafka services.

Example Usage

using Pulumi;
using Aiven = Pulumi.Aiven;

class MyStack : Stack
{
    public MyStack()
    {
        var kafka1 = Output.Create(Aiven.GetKafka.InvokeAsync(new Aiven.GetKafkaArgs
        {
            Project = data.Aiven_project.Pr1.Project,
            ServiceName = "my-kafka1",
        }));
    }

}
package main

import (
	"github.com/pulumi/pulumi-aiven/sdk/v5/go/aiven"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := aiven.LookupKafka(ctx, &GetKafkaArgs{
			Project:     data.Aiven_project.Pr1.Project,
			ServiceName: "my-kafka1",
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}
package generated_program;

import java.util.*;
import java.io.*;
import java.nio.*;
import com.pulumi.*;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        final var kafka1 = Output.of(AivenFunctions.getKafka(GetKafkaArgs.builder()
            .project(data.aiven_project().pr1().project())
            .serviceName("my-kafka1")
            .build()));

    }
}
import pulumi
import pulumi_aiven as aiven

kafka1 = aiven.get_kafka(project=data["aiven_project"]["pr1"]["project"],
    service_name="my-kafka1")
import * as pulumi from "@pulumi/pulumi";
import * as aiven from "@pulumi/aiven";

const kafka1 = aiven.getKafka({
    project: data.aiven_project.pr1.project,
    serviceName: "my-kafka1",
});
variables:
  kafka1:
    Fn::Invoke:
      Function: aiven:getKafka
      Arguments:
        project: ${data.aiven_project.pr1.project}
        serviceName: my-kafka1

Using getKafka

Two invocation forms are available. The direct form accepts plain arguments and either blocks until the result value is available, or returns a Promise-wrapped result. The output form accepts Input-wrapped arguments and returns an Output-wrapped result.

function getKafka(args: GetKafkaArgs, opts?: InvokeOptions): Promise<GetKafkaResult>
function getKafkaOutput(args: GetKafkaOutputArgs, opts?: InvokeOptions): Output<GetKafkaResult>
def get_kafka(project: Optional[str] = None,
              service_name: Optional[str] = None,
              opts: Optional[InvokeOptions] = None) -> GetKafkaResult
def get_kafka_output(project: Optional[pulumi.Input[str]] = None,
              service_name: Optional[pulumi.Input[str]] = None,
              opts: Optional[InvokeOptions] = None) -> Output[GetKafkaResult]
func LookupKafka(ctx *Context, args *LookupKafkaArgs, opts ...InvokeOption) (*LookupKafkaResult, error)
func LookupKafkaOutput(ctx *Context, args *LookupKafkaOutputArgs, opts ...InvokeOption) LookupKafkaResultOutput

> Note: This function is named LookupKafka in the Go SDK.

public static class GetKafka 
{
    public static Task<GetKafkaResult> InvokeAsync(GetKafkaArgs args, InvokeOptions? opts = null)
    public static Output<GetKafkaResult> Invoke(GetKafkaInvokeArgs args, InvokeOptions? opts = null)
}
public static CompletableFuture<GetKafkaResult> getKafka(GetKafkaArgs args, InvokeOptions options)
// Output-based functions aren't available in Java yet
Fn::Invoke:
  Function: aiven:index/getKafka:getKafka
  Arguments:
    # Arguments dictionary

The following arguments are supported:

Project string
ServiceName string
Project string
ServiceName string
project String
serviceName String
project string
serviceName string
project String
serviceName String

getKafka Result

The following output properties are available:

Supporting Types

GetKafkaComponent

Component string
Host string
KafkaAuthenticationMethod string
Port int
Route string
Ssl bool
Usage string
Component string
Host string
KafkaAuthenticationMethod string
Port int
Route string
Ssl bool
Usage string
component String
host String
kafkaAuthenticationMethod String
port Integer
route String
ssl Boolean
usage String
component string
host string
kafkaAuthenticationMethod string
port number
route string
ssl boolean
usage string
component String
host String
kafkaAuthenticationMethod String
port Number
route String
ssl Boolean
usage String

GetKafkaKafka

GetKafkaKafkaUserConfig

GetKafkaKafkaUserConfigKafka

AutoCreateTopicsEnable string
CompressionType string
ConnectionsMaxIdleMs string
DefaultReplicationFactor string
GroupInitialRebalanceDelayMs string
GroupMaxSessionTimeoutMs string
GroupMinSessionTimeoutMs string
LogCleanerDeleteRetentionMs string
LogCleanerMaxCompactionLagMs string
LogCleanerMinCleanableRatio string
LogCleanerMinCompactionLagMs string
LogCleanupPolicy string
LogFlushIntervalMessages string
LogFlushIntervalMs string
LogIndexIntervalBytes string
LogIndexSizeMaxBytes string
LogMessageDownconversionEnable string
LogMessageTimestampDifferenceMaxMs string
LogMessageTimestampType string
LogPreallocate string
LogRetentionBytes string
LogRetentionHours string
LogRetentionMs string
LogRollJitterMs string
LogRollMs string
LogSegmentBytes string
LogSegmentDeleteDelayMs string
MaxConnectionsPerIp string
MaxIncrementalFetchSessionCacheSlots string
MessageMaxBytes string
MinInsyncReplicas string
NumPartitions string
OffsetsRetentionMinutes string
ProducerPurgatoryPurgeIntervalRequests string
ReplicaFetchMaxBytes string
ReplicaFetchResponseMaxBytes string
SocketRequestMaxBytes string
TransactionRemoveExpiredTransactionCleanupIntervalMs string
TransactionStateLogSegmentBytes string
AutoCreateTopicsEnable string
CompressionType string
ConnectionsMaxIdleMs string
DefaultReplicationFactor string
GroupInitialRebalanceDelayMs string
GroupMaxSessionTimeoutMs string
GroupMinSessionTimeoutMs string
LogCleanerDeleteRetentionMs string
LogCleanerMaxCompactionLagMs string
LogCleanerMinCleanableRatio string
LogCleanerMinCompactionLagMs string
LogCleanupPolicy string
LogFlushIntervalMessages string
LogFlushIntervalMs string
LogIndexIntervalBytes string
LogIndexSizeMaxBytes string
LogMessageDownconversionEnable string
LogMessageTimestampDifferenceMaxMs string
LogMessageTimestampType string
LogPreallocate string
LogRetentionBytes string
LogRetentionHours string
LogRetentionMs string
LogRollJitterMs string
LogRollMs string
LogSegmentBytes string
LogSegmentDeleteDelayMs string
MaxConnectionsPerIp string
MaxIncrementalFetchSessionCacheSlots string
MessageMaxBytes string
MinInsyncReplicas string
NumPartitions string
OffsetsRetentionMinutes string
ProducerPurgatoryPurgeIntervalRequests string
ReplicaFetchMaxBytes string
ReplicaFetchResponseMaxBytes string
SocketRequestMaxBytes string
TransactionRemoveExpiredTransactionCleanupIntervalMs string
TransactionStateLogSegmentBytes string
autoCreateTopicsEnable String
compressionType String
connectionsMaxIdleMs String
defaultReplicationFactor String
groupInitialRebalanceDelayMs String
groupMaxSessionTimeoutMs String
groupMinSessionTimeoutMs String
logCleanerDeleteRetentionMs String
logCleanerMaxCompactionLagMs String
logCleanerMinCleanableRatio String
logCleanerMinCompactionLagMs String
logCleanupPolicy String
logFlushIntervalMessages String
logFlushIntervalMs String
logIndexIntervalBytes String
logIndexSizeMaxBytes String
logMessageDownconversionEnable String
logMessageTimestampDifferenceMaxMs String
logMessageTimestampType String
logPreallocate String
logRetentionBytes String
logRetentionHours String
logRetentionMs String
logRollJitterMs String
logRollMs String
logSegmentBytes String
logSegmentDeleteDelayMs String
maxConnectionsPerIp String
maxIncrementalFetchSessionCacheSlots String
messageMaxBytes String
minInsyncReplicas String
numPartitions String
offsetsRetentionMinutes String
producerPurgatoryPurgeIntervalRequests String
replicaFetchMaxBytes String
replicaFetchResponseMaxBytes String
socketRequestMaxBytes String
transactionRemoveExpiredTransactionCleanupIntervalMs String
transactionStateLogSegmentBytes String
autoCreateTopicsEnable string
compressionType string
connectionsMaxIdleMs string
defaultReplicationFactor string
groupInitialRebalanceDelayMs string
groupMaxSessionTimeoutMs string
groupMinSessionTimeoutMs string
logCleanerDeleteRetentionMs string
logCleanerMaxCompactionLagMs string
logCleanerMinCleanableRatio string
logCleanerMinCompactionLagMs string
logCleanupPolicy string
logFlushIntervalMessages string
logFlushIntervalMs string
logIndexIntervalBytes string
logIndexSizeMaxBytes string
logMessageDownconversionEnable string
logMessageTimestampDifferenceMaxMs string
logMessageTimestampType string
logPreallocate string
logRetentionBytes string
logRetentionHours string
logRetentionMs string
logRollJitterMs string
logRollMs string
logSegmentBytes string
logSegmentDeleteDelayMs string
maxConnectionsPerIp string
maxIncrementalFetchSessionCacheSlots string
messageMaxBytes string
minInsyncReplicas string
numPartitions string
offsetsRetentionMinutes string
producerPurgatoryPurgeIntervalRequests string
replicaFetchMaxBytes string
replicaFetchResponseMaxBytes string
socketRequestMaxBytes string
transactionRemoveExpiredTransactionCleanupIntervalMs string
transactionStateLogSegmentBytes string
auto_create_topics_enable str
compression_type str
connections_max_idle_ms str
default_replication_factor str
group_initial_rebalance_delay_ms str
group_max_session_timeout_ms str
group_min_session_timeout_ms str
log_cleaner_delete_retention_ms str
log_cleaner_max_compaction_lag_ms str
log_cleaner_min_cleanable_ratio str
log_cleaner_min_compaction_lag_ms str
log_cleanup_policy str
log_flush_interval_messages str
log_flush_interval_ms str
log_index_interval_bytes str
log_index_size_max_bytes str
log_message_downconversion_enable str
log_message_timestamp_difference_max_ms str
log_message_timestamp_type str
log_preallocate str
log_retention_bytes str
log_retention_hours str
log_retention_ms str
log_roll_jitter_ms str
log_roll_ms str
log_segment_bytes str
log_segment_delete_delay_ms str
max_connections_per_ip str
max_incremental_fetch_session_cache_slots str
message_max_bytes str
min_insync_replicas str
num_partitions str
offsets_retention_minutes str
producer_purgatory_purge_interval_requests str
replica_fetch_max_bytes str
replica_fetch_response_max_bytes str
socket_request_max_bytes str
transaction_remove_expired_transaction_cleanup_interval_ms str
transaction_state_log_segment_bytes str
autoCreateTopicsEnable String
compressionType String
connectionsMaxIdleMs String
defaultReplicationFactor String
groupInitialRebalanceDelayMs String
groupMaxSessionTimeoutMs String
groupMinSessionTimeoutMs String
logCleanerDeleteRetentionMs String
logCleanerMaxCompactionLagMs String
logCleanerMinCleanableRatio String
logCleanerMinCompactionLagMs String
logCleanupPolicy String
logFlushIntervalMessages String
logFlushIntervalMs String
logIndexIntervalBytes String
logIndexSizeMaxBytes String
logMessageDownconversionEnable String
logMessageTimestampDifferenceMaxMs String
logMessageTimestampType String
logPreallocate String
logRetentionBytes String
logRetentionHours String
logRetentionMs String
logRollJitterMs String
logRollMs String
logSegmentBytes String
logSegmentDeleteDelayMs String
maxConnectionsPerIp String
maxIncrementalFetchSessionCacheSlots String
messageMaxBytes String
minInsyncReplicas String
numPartitions String
offsetsRetentionMinutes String
producerPurgatoryPurgeIntervalRequests String
replicaFetchMaxBytes String
replicaFetchResponseMaxBytes String
socketRequestMaxBytes String
transactionRemoveExpiredTransactionCleanupIntervalMs String
transactionStateLogSegmentBytes String

GetKafkaKafkaUserConfigKafkaAuthenticationMethods

Certificate string
Sasl string
Certificate string
Sasl string
certificate String
sasl String
certificate string
sasl string
certificate String
sasl String

GetKafkaKafkaUserConfigKafkaConnectConfig

GetKafkaKafkaUserConfigKafkaRestConfig

GetKafkaKafkaUserConfigPrivateAccess

Prometheus string
Prometheus string
prometheus String
prometheus string
prometheus String

GetKafkaKafkaUserConfigPrivatelinkAccess

Jolokia string
Kafka string
KafkaConnect string
KafkaRest string
Prometheus string
SchemaRegistry string
Jolokia string
Kafka string
KafkaConnect string
KafkaRest string
Prometheus string
SchemaRegistry string
jolokia String
kafka String
kafkaConnect String
kafkaRest String
prometheus String
schemaRegistry String
jolokia string
kafka string
kafkaConnect string
kafkaRest string
prometheus string
schemaRegistry string
jolokia String
kafka String
kafkaConnect String
kafkaRest String
prometheus String
schemaRegistry String

GetKafkaKafkaUserConfigPublicAccess

Kafka string
KafkaConnect string
KafkaRest string
Prometheus string
SchemaRegistry string
Kafka string
KafkaConnect string
KafkaRest string
Prometheus string
SchemaRegistry string
kafka String
kafkaConnect String
kafkaRest String
prometheus String
schemaRegistry String
kafka string
kafkaConnect string
kafkaRest string
prometheus string
schemaRegistry string
kafka String
kafkaConnect String
kafkaRest String
prometheus String
schemaRegistry String

GetKafkaKafkaUserConfigSchemaRegistryConfig

GetKafkaServiceIntegration

GetKafkaTag

Key string
Value string
Key string
Value string
key String
value String
key string
value string
key str
value str
key String
value String

Package Details

Repository
https://github.com/pulumi/pulumi-aiven
License
Apache-2.0
Notes

This Pulumi package is based on the aiven Terraform Provider.