Function writeToKafka

writeToKafka<K, V>(producerConfig: {
    [key: string]: string;
}, topics: string[], options?: WriteToKafkaOptions): AsyncPTransform<PCollection<{
    key: K;
    value: V;
}>, {}>
Type Parameters
- K = Uint8Array
- V = Uint8Array
Parameters
- producerConfig: {
  [key: string]: string;
  }
  - [key: string]: string
- topics: string[]
- options: WriteToKafkaOptions = {}
Returns AsyncPTransform<PCollection<{
key: K;
value: V;
}>, {}>
- Defined in src/apache_beam/io/kafka.ts:107

Generated using TypeDoc