Skip to content

Commit

Permalink
[hotfix][docs][kafka] Fix code formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
Fokko authored and zentol committed Feb 12, 2019
1 parent 7eb4072 commit 70f466b
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions docs/dev/connectors/kafka.md
Original file line number Diff line number Diff line change
Expand Up @@ -205,7 +205,7 @@ produced Java/Scala type to Flink's type system. Users that implement a vanilla
to implement the `getProducedType(...)` method themselves.

For accessing both the key and value of the Kafka message, the `KeyedDeserializationSchema` has
the following deserialize method ` T deserialize(byte[] messageKey, byte[] message, String topic, int partition, long offset)`.
the following deserialize method `T deserialize(byte[] messageKey, byte[] message, String topic, int partition, long offset)`.

For convenience, Flink provides the following schemas:

Expand All @@ -214,7 +214,7 @@ For convenience, Flink provides the following schemas:
This schema is a performant Flink-specific alternative to other generic serialization approaches.

2. `JsonDeserializationSchema` (and `JSONKeyValueDeserializationSchema`) which turns the serialized JSON
into an ObjectNode object, from which fields can be accessed using objectNode.get("field").as(Int/String/...)().
into an ObjectNode object, from which fields can be accessed using `objectNode.get("field").as(Int/String/...)()`.
The KeyValue objectNode contains a "key" and "value" field which contain all fields, as well as
an optional "metadata" field that exposes the offset/partition/topic for this message.

Expand Down

0 comments on commit 70f466b

Please sign in to comment.