Package io.deephaven.kafka

Interface KafkaPublishOptions.Builder

Enclosing class:

KafkaPublishOptions

public static interface KafkaPublishOptions.Builder

Method Summary

Modifier and Type	Method	Description
KafkaPublishOptions	build()
KafkaPublishOptions.Builder	config(Properties config)
KafkaPublishOptions.Builder	keySpec(KafkaTools.Produce.KeyOrValueSpec keySpec)
KafkaPublishOptions.Builder	lastBy(boolean lastBy)
KafkaPublishOptions.Builder	partition(int partition)
KafkaPublishOptions.Builder	partitionColumn(ColumnName columnName)
KafkaPublishOptions.Builder	publishInitial(boolean publishInitial)
KafkaPublishOptions.Builder	table(Table table)
KafkaPublishOptions.Builder	timestampColumn(ColumnName columnName)
KafkaPublishOptions.Builder	topic(String topic)
KafkaPublishOptions.Builder	topicColumn(ColumnName columnName)
KafkaPublishOptions.Builder	valueSpec(KafkaTools.Produce.KeyOrValueSpec valueSpec)

Method Details

table

KafkaPublishOptions.Builder table(Table table)

topic

KafkaPublishOptions.Builder topic(String topic)

partition

KafkaPublishOptions.Builder partition(int partition)

config

KafkaPublishOptions.Builder config(Properties config)

keySpec

KafkaPublishOptions.Builder keySpec(KafkaTools.Produce.KeyOrValueSpec keySpec)

valueSpec

KafkaPublishOptions.Builder valueSpec(KafkaTools.Produce.KeyOrValueSpec valueSpec)

lastBy

KafkaPublishOptions.Builder lastBy(boolean lastBy)

publishInitial

KafkaPublishOptions.Builder publishInitial(boolean publishInitial)

topicColumn

KafkaPublishOptions.Builder topicColumn(ColumnName columnName)

partitionColumn

KafkaPublishOptions.Builder partitionColumn(ColumnName columnName)

timestampColumn

KafkaPublishOptions.Builder timestampColumn(ColumnName columnName)

build

KafkaPublishOptions build()