PipeSourceParametersManagedStreamingKafkaParameters (com.pulumi.aws API)

java.lang.Object
- com.pulumi.aws.pipes.outputs.PipeSourceParametersManagedStreamingKafkaParameters

public final class PipeSourceParametersManagedStreamingKafkaParameters
extends java.lang.Object

Nested Class Summary

Nested Classes
Modifier and Type Class Description

static class PipeSourceParametersManagedStreamingKafkaParameters.Builder

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`java.util.Optional<java.lang.Integer>`	`batchSize()`
`static PipeSourceParametersManagedStreamingKafkaParameters.Builder`	`builder()`
`static PipeSourceParametersManagedStreamingKafkaParameters.Builder`	`builder(PipeSourceParametersManagedStreamingKafkaParameters defaults)`
`java.util.Optional<java.lang.String>`	`consumerGroupId()`
`java.util.Optional<PipeSourceParametersManagedStreamingKafkaParametersCredentials>`	`credentials()`
`java.util.Optional<java.lang.Integer>`	`maximumBatchingWindowInSeconds()`
`java.util.Optional<java.lang.String>`	`startingPosition()`
`java.lang.String`	`topicName()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Method Detail
  - batchSize
```
public java.util.Optional<java.lang.Integer> batchSize()
```
    Returns:
    
    Maximum number of records to include in each batch. Maximum value of 10000.
  - consumerGroupId
```
public java.util.Optional<java.lang.String> consumerGroupId()
```
    Returns:
    
    Name of the destination queue to consume. Maximum value of 200.
  - credentials
```
public java.util.Optional<PipeSourceParametersManagedStreamingKafkaParametersCredentials> credentials()
```
    Returns:
    
    Credentials needed to access the resource. See `source_parameters.managed_streaming_kafka_parameters.credentials` Block for details.
  - maximumBatchingWindowInSeconds
```
public java.util.Optional<java.lang.Integer> maximumBatchingWindowInSeconds()
```
    Returns:
    
    Maximum length of a time to wait for events. Maximum value of 300.
  - startingPosition
```
public java.util.Optional<java.lang.String> startingPosition()
```
    Returns:
    
    Position in a stream from which to start reading. Valid values: TRIM_HORIZON, LATEST.
  - topicName
```
public java.lang.String topicName()
```
    Returns:
    
    Name of the topic that the pipe will read from. Maximum length of 249.
  - builder
```
public static PipeSourceParametersManagedStreamingKafkaParameters.Builder builder()
```
  - builder
```
public static PipeSourceParametersManagedStreamingKafkaParameters.Builder builder(PipeSourceParametersManagedStreamingKafkaParameters defaults)
```