static KafkaEgressMessage.Builder |
KafkaEgressMessage.forEgress(TypeName targetEgressId) |
KafkaEgressMessage.Builder |
KafkaEgressMessage.Builder.withKey(byte[] key) |
KafkaEgressMessage.Builder |
KafkaEgressMessage.Builder.withKey(Slice slice) |
<T> KafkaEgressMessage.Builder |
KafkaEgressMessage.Builder.withKey(Type<T> type,
T value) |
KafkaEgressMessage.Builder |
KafkaEgressMessage.Builder.withTopic(Slice topic) |
KafkaEgressMessage.Builder |
KafkaEgressMessage.Builder.withTopic(java.lang.String topic) |
KafkaEgressMessage.Builder |
KafkaEgressMessage.Builder.withUtf8Key(java.lang.String key) |
KafkaEgressMessage.Builder |
KafkaEgressMessage.Builder.withUtf8Value(java.lang.String value) |
KafkaEgressMessage.Builder |
KafkaEgressMessage.Builder.withValue(byte[] value) |
KafkaEgressMessage.Builder |
KafkaEgressMessage.Builder.withValue(Slice slice) |
<T> KafkaEgressMessage.Builder |
KafkaEgressMessage.Builder.withValue(Type<T> type,
T value) |