Serialized Form (kafka 2.52.0 API)

Package org.apache.beam.sdk.io.kafka
- Class org.apache.beam.sdk.io.kafka.ConfluentSchemaRegistryDeserializerProvider extends java.lang.Object implements Serializable
  - Serialized Fields
    - schemaRegistryClientProviderFn
```
org.apache.beam.sdk.transforms.SerializableFunction<InputT,OutputT> schemaRegistryClientProviderFn
```
    - schemaRegistryUrl
```
java.lang.String schemaRegistryUrl
```
    - subject
```
java.lang.String subject
```
    - version
```
java.lang.Integer version
```
- Class org.apache.beam.sdk.io.kafka.KafkaCheckpointMark.PartitionMark extends java.lang.Object implements Serializable
  - Serialized Fields
    - topic
```
java.lang.String topic
```
    - partition
```
int partition
```
    - nextOffset
```
long nextOffset
```
    - watermarkMillis
```
long watermarkMillis
```
- Class org.apache.beam.sdk.io.kafka.KafkaCommitOffset extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<KafkaSourceDescriptor,KafkaRecord<K,V>>>,org.apache.beam.sdk.values.PCollection<java.lang.Void>> implements Serializable
  - Serialized Fields
    - readSourceDescriptors
```
KafkaIO.ReadSourceDescriptors<K,V> readSourceDescriptors
```
- Class org.apache.beam.sdk.io.kafka.KafkaIO.Read extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PBegin,org.apache.beam.sdk.values.PCollection<KafkaRecord<K,V>>> implements Serializable
- Class org.apache.beam.sdk.io.kafka.KafkaIO.ReadSourceDescriptors extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<KafkaSourceDescriptor>,org.apache.beam.sdk.values.PCollection<KafkaRecord<K,V>>> implements Serializable
- Class org.apache.beam.sdk.io.kafka.KafkaIO.TypedWithoutMetadata extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PBegin,org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<K,V>>> implements Serializable
  - Serialized Fields
    - read
```
KafkaIO.Read<K,V> read
```
- Class org.apache.beam.sdk.io.kafka.KafkaIO.Write extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<K,V>>,org.apache.beam.sdk.values.PDone> implements Serializable
- Class org.apache.beam.sdk.io.kafka.KafkaIO.WriteRecords extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.kafka.clients.producer.ProducerRecord<K,V>>,org.apache.beam.sdk.values.PDone> implements Serializable
- Class org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProvider.ErrorFn extends org.apache.beam.sdk.transforms.DoFn<byte[],org.apache.beam.sdk.values.Row> implements Serializable
  - Serialized Fields
    - valueMapper
```
org.apache.beam.sdk.transforms.SerializableFunction<InputT,OutputT> valueMapper
```
    - errorCounter
```
org.apache.beam.sdk.metrics.Counter errorCounter
```
    - errorsInBundle
```
java.lang.Long errorsInBundle
```
    - handleErrors
```
boolean handleErrors
```
    - errorSchema
```
org.apache.beam.sdk.schemas.Schema errorSchema
```
- Class org.apache.beam.sdk.io.kafka.KafkaRecordCoder extends org.apache.beam.sdk.coders.StructuredCoder<KafkaRecord<K,V>> implements Serializable
  - Serialized Fields
    - kvCoder
```
org.apache.beam.sdk.coders.KvCoder<K,V> kvCoder
```
- Class org.apache.beam.sdk.io.kafka.KafkaSourceDescriptor extends java.lang.Object implements Serializable
  - Serialized Fields
    - topicPartition
```
org.apache.kafka.common.TopicPartition topicPartition
```
- Class org.apache.beam.sdk.io.kafka.KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransform.ErrorCounterFn extends org.apache.beam.sdk.transforms.DoFn<org.apache.beam.sdk.values.Row,org.apache.beam.sdk.values.KV<byte[],byte[]>> implements Serializable
  - Serialized Fields
    - toBytesFn
```
org.apache.beam.sdk.transforms.SerializableFunction<InputT,OutputT> toBytesFn
```
    - errorCounter
```
org.apache.beam.sdk.metrics.Counter errorCounter
```
    - errorsInBundle
```
java.lang.Long errorsInBundle
```
    - handleErrors
```
boolean handleErrors
```
    - errorSchema
```
org.apache.beam.sdk.schemas.Schema errorSchema
```
- Class org.apache.beam.sdk.io.kafka.KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration extends java.lang.Object implements Serializable
- Class org.apache.beam.sdk.io.kafka.ProducerRecordCoder extends org.apache.beam.sdk.coders.StructuredCoder<org.apache.kafka.clients.producer.ProducerRecord<K,V>> implements Serializable
  - Serialized Fields
    - kvCoder
```
org.apache.beam.sdk.coders.KvCoder<K,V> kvCoder
```
- Class org.apache.beam.sdk.io.kafka.TopicPartitionCoder extends org.apache.beam.sdk.coders.StructuredCoder<org.apache.kafka.common.TopicPartition> implements Serializable

Serialized Form

Package org.apache.beam.sdk.io.kafka

Class org.apache.beam.sdk.io.kafka.ConfluentSchemaRegistryDeserializerProvider extends java.lang.Object implements Serializable

Serialized Fields

schemaRegistryClientProviderFn

schemaRegistryUrl

subject

version

Class org.apache.beam.sdk.io.kafka.KafkaCheckpointMark.PartitionMark extends java.lang.Object implements Serializable

Serialized Fields

topic

partition

nextOffset

watermarkMillis

Class org.apache.beam.sdk.io.kafka.KafkaCommitOffset extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<KafkaSourceDescriptor,KafkaRecord<K,V>>>,org.apache.beam.sdk.values.PCollection<java.lang.Void>> implements Serializable

Serialized Fields

readSourceDescriptors

Class org.apache.beam.sdk.io.kafka.KafkaIO.Read extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PBegin,org.apache.beam.sdk.values.PCollection<KafkaRecord<K,V>>> implements Serializable

Class org.apache.beam.sdk.io.kafka.KafkaIO.ReadSourceDescriptors extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<KafkaSourceDescriptor>,org.apache.beam.sdk.values.PCollection<KafkaRecord<K,V>>> implements Serializable

Class org.apache.beam.sdk.io.kafka.KafkaIO.TypedWithoutMetadata extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PBegin,org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<K,V>>> implements Serializable

Serialized Fields

read

Class org.apache.beam.sdk.io.kafka.KafkaIO.Write extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<K,V>>,org.apache.beam.sdk.values.PDone> implements Serializable

Class org.apache.beam.sdk.io.kafka.KafkaIO.WriteRecords extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.kafka.clients.producer.ProducerRecord<K,V>>,org.apache.beam.sdk.values.PDone> implements Serializable

Class org.apache.beam.sdk.io.kafka.KafkaReadSchemaTransformProvider.ErrorFn extends org.apache.beam.sdk.transforms.DoFn<byte[],org.apache.beam.sdk.values.Row> implements Serializable

Serialized Fields

valueMapper

errorCounter

errorsInBundle

handleErrors

errorSchema

Class org.apache.beam.sdk.io.kafka.KafkaRecordCoder extends org.apache.beam.sdk.coders.StructuredCoder<KafkaRecord<K,V>> implements Serializable

Serialized Fields

kvCoder

Class org.apache.beam.sdk.io.kafka.KafkaSourceDescriptor extends java.lang.Object implements Serializable

Serialized Fields

topicPartition

Class org.apache.beam.sdk.io.kafka.KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransform.ErrorCounterFn extends org.apache.beam.sdk.transforms.DoFn<org.apache.beam.sdk.values.Row,org.apache.beam.sdk.values.KV<byte[],byte[]>> implements Serializable

Serialized Fields

toBytesFn

errorCounter

errorsInBundle

handleErrors

errorSchema

Class org.apache.beam.sdk.io.kafka.KafkaWriteSchemaTransformProvider.KafkaWriteSchemaTransformConfiguration extends java.lang.Object implements Serializable

Class org.apache.beam.sdk.io.kafka.ProducerRecordCoder extends org.apache.beam.sdk.coders.StructuredCoder<org.apache.kafka.clients.producer.ProducerRecord<K,V>> implements Serializable

Serialized Fields

kvCoder

Class org.apache.beam.sdk.io.kafka.TopicPartitionCoder extends org.apache.beam.sdk.coders.StructuredCoder<org.apache.kafka.common.TopicPartition> implements Serializable