public void setLogFailuresOnly(boolean logFailuresOnly)
Defines whether the producer should fail on errors, or only log them.
If this is set to true, then exceptions will be only logged, if set to false,
exceptions will be eventually thrown and cause the streaming program to
fail (and enter recovery).
logFailuresOnly - The flag to indicate logging-only on exceptions.
public void setFlushOnCheckpoint(boolean flush)
If set to true, the Flink producer will wait for all outstanding messages in the Kafka buffers
to be acknowledged by the Kafka producer on a checkpoint.
This way, the producer can guarantee that messages in the Kafka buffers are part of the checkpoint.
flush - Flag indicating the flushing mode (true = flush on checkpoint)
public void setWriteTimestampToKafka(boolean writeTimestampToKafka)
If set to true, Flink will write the (event time) timestamp attached to each record into Kafka.
Timestamps must be positive for Kafka to accept them.
writeTimestampToKafka - Flag indicating if Flink's internal timestamps are written to Kafka.