Class: Aws::Pipes::Types::PipeSourceSelfManagedKafkaParameters

Inherits:
Struct
  • Object
show all
Defined in:
gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb

Overview

The parameters for using a self-managed Apache Kafka stream as a source.

See Also:

Constant Summary collapse

SENSITIVE = 
[:consumer_group_id, :topic_name]

Instance Attribute Summary collapse

Instance Attribute Details

#additional_bootstrap_servers ⇒ Array<String>

An array of server URLs.

Returns:

  • (Array<String>) 


1917
1918
1919
1920
1921
1922
1923
1924
1925
1926
1927
1928
1929
 
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 1917

class PipeSourceSelfManagedKafkaParameters < Struct.new(
  :additional_bootstrap_servers,
  :batch_size,
  :consumer_group_id,
  :credentials,
  :maximum_batching_window_in_seconds,
  :server_root_ca_certificate,
  :starting_position,
  :topic_name,
  :vpc)
  SENSITIVE = [:consumer_group_id, :topic_name]
  include Aws::Structure
end

#batch_size ⇒ Integer

The maximum number of records to include in each batch.

Returns:

  • (Integer) 


1917
1918
1919
1920
1921
1922
1923
1924
1925
1926
1927
1928
1929
 
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 1917

class PipeSourceSelfManagedKafkaParameters < Struct.new(
  :additional_bootstrap_servers,
  :batch_size,
  :consumer_group_id,
  :credentials,
  :maximum_batching_window_in_seconds,
  :server_root_ca_certificate,
  :starting_position,
  :topic_name,
  :vpc)
  SENSITIVE = [:consumer_group_id, :topic_name]
  include Aws::Structure
end

#consumer_group_id ⇒ String

The name of the destination queue to consume.

Returns:

  • (String) 


1917
1918
1919
1920
1921
1922
1923
1924
1925
1926
1927
1928
1929
 
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 1917

class PipeSourceSelfManagedKafkaParameters < Struct.new(
  :additional_bootstrap_servers,
  :batch_size,
  :consumer_group_id,
  :credentials,
  :maximum_batching_window_in_seconds,
  :server_root_ca_certificate,
  :starting_position,
  :topic_name,
  :vpc)
  SENSITIVE = [:consumer_group_id, :topic_name]
  include Aws::Structure
end

#credentials ⇒ Types::SelfManagedKafkaAccessConfigurationCredentials

The credentials needed to access the resource.

Returns:



1917
1918
1919
1920
1921
1922
1923
1924
1925
1926
1927
1928
1929
 
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 1917

class PipeSourceSelfManagedKafkaParameters < Struct.new(
  :additional_bootstrap_servers,
  :batch_size,
  :consumer_group_id,
  :credentials,
  :maximum_batching_window_in_seconds,
  :server_root_ca_certificate,
  :starting_position,
  :topic_name,
  :vpc)
  SENSITIVE = [:consumer_group_id, :topic_name]
  include Aws::Structure
end

#maximum_batching_window_in_seconds ⇒ Integer

The maximum length of a time to wait for events.

Returns:

  • (Integer) 


1917
1918
1919
1920
1921
1922
1923
1924
1925
1926
1927
1928
1929
 
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 1917

class PipeSourceSelfManagedKafkaParameters < Struct.new(
  :additional_bootstrap_servers,
  :batch_size,
  :consumer_group_id,
  :credentials,
  :maximum_batching_window_in_seconds,
  :server_root_ca_certificate,
  :starting_position,
  :topic_name,
  :vpc)
  SENSITIVE = [:consumer_group_id, :topic_name]
  include Aws::Structure
end

#server_root_ca_certificate ⇒ String

The ARN of the Secrets Manager secret used for certification.

Returns:

  • (String) 


1917
1918
1919
1920
1921
1922
1923
1924
1925
1926
1927
1928
1929
 
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 1917

class PipeSourceSelfManagedKafkaParameters < Struct.new(
  :additional_bootstrap_servers,
  :batch_size,
  :consumer_group_id,
  :credentials,
  :maximum_batching_window_in_seconds,
  :server_root_ca_certificate,
  :starting_position,
  :topic_name,
  :vpc)
  SENSITIVE = [:consumer_group_id, :topic_name]
  include Aws::Structure
end

#starting_position ⇒ String

(Streams only) The position in a stream from which to start reading.

Returns:

  • (String) 


1917
1918
1919
1920
1921
1922
1923
1924
1925
1926
1927
1928
1929
 
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 1917

class PipeSourceSelfManagedKafkaParameters < Struct.new(
  :additional_bootstrap_servers,
  :batch_size,
  :consumer_group_id,
  :credentials,
  :maximum_batching_window_in_seconds,
  :server_root_ca_certificate,
  :starting_position,
  :topic_name,
  :vpc)
  SENSITIVE = [:consumer_group_id, :topic_name]
  include Aws::Structure
end

#topic_name ⇒ String

The name of the topic that the pipe will read from.

Returns:

  • (String) 


1917
1918
1919
1920
1921
1922
1923
1924
1925
1926
1927
1928
1929
 
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 1917

class PipeSourceSelfManagedKafkaParameters < Struct.new(
  :additional_bootstrap_servers,
  :batch_size,
  :consumer_group_id,
  :credentials,
  :maximum_batching_window_in_seconds,
  :server_root_ca_certificate,
  :starting_position,
  :topic_name,
  :vpc)
  SENSITIVE = [:consumer_group_id, :topic_name]
  include Aws::Structure
end

#vpc ⇒ Types::SelfManagedKafkaAccessConfigurationVpc

This structure specifies the VPC subnets and security groups for the stream, and whether a public IP address is to be used.

Returns:



1917
1918
1919
1920
1921
1922
1923
1924
1925
1926
1927
1928
1929
 
# File 'gems/aws-sdk-pipes/lib/aws-sdk-pipes/types.rb', line 1917

class PipeSourceSelfManagedKafkaParameters < Struct.new(
  :additional_bootstrap_servers,
  :batch_size,
  :consumer_group_id,
  :credentials,
  :maximum_batching_window_in_seconds,
  :server_root_ca_certificate,
  :starting_position,
  :topic_name,
  :vpc)
  SENSITIVE = [:consumer_group_id, :topic_name]
  include Aws::Structure
end