Skip to content

Commit

Permalink
Merge pull request #3 from echauchot/fix_pr_5019
Browse files Browse the repository at this point in the history
Fix checkstyle
  • Loading branch information
aromanenko-dev authored Apr 5, 2018
2 parents fe535cb + 6e046a0 commit 2e744e5
Showing 1 changed file with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -789,8 +789,9 @@ public void processElement(ProcessContext c) {
* Send {@code events} to Kafka.
*/
private void sinkEventsToKafka(PCollection<Event> events) {
PCollection<byte[]> event_to_bytes = events.apply("Event to bytes", ParDo.of(EVENT_TO_BYTEARRAY));
event_to_bytes.apply(KafkaIO.<Void, byte[]>write()
PCollection<byte[]> eventToBytes =
events.apply("Event to bytes", ParDo.of(EVENT_TO_BYTEARRAY));
eventToBytes.apply(KafkaIO.<Void, byte[]>write()
.withBootstrapServers(options.getBootstrapServers())
.withTopic(options.getKafkaSinkTopic())
.withValueSerializer(ByteArraySerializer.class)
Expand Down

0 comments on commit 2e744e5

Please sign in to comment.