File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change 1
1
# KafkaIO : Dataflow Unbounded Source and Sink for Kafka Topics
2
2
3
- KafkaIO provides unbounded sources and sinks for [ Kafka] ( https ://www.firebase.com /)
4
- topics. Kafka version 0.9 and above are supported.
3
+ KafkaIO provides unbounded source and sink for [ Kafka] ( http ://kafka.apache.org /)
4
+ topics. Kafka versions 0.9 and above are supported.
5
5
6
6
## Basic Usage
7
7
8
8
* Read from a topic with 8 byte long keys and string values:
9
9
``` java
10
10
PCollection<KV<Long , String > > kafkaRecords =
11
11
pipeline
12
- .applY (KafkaIO . read()
12
+ .apply (KafkaIO . read()
13
13
.withBootstrapServers(" broker_1:9092,broker_2:9092" )
14
14
.withTopics(ImmutableList . of(" topic_a" ))
15
15
.withKeyCoder(BigEndianLongCoder . of())
@@ -25,6 +25,7 @@ topics. Kafka version 0.9 and above are supported.
25
25
.withTopic(" results" )
26
26
.withKeyCoder(BigEndianLongCoder . of())
27
27
.withValueCoder(StringUtf8Coder . of())
28
+ );
28
29
```
29
30
30
31
Please see JavaDoc for KafkaIO in
You can’t perform that action at this time.
0 commit comments