Interface KafkaHeaders
-
@Immutable @DoNotImplement public interface KafkaHeaders
This interface contains allKafkaHeader
s belonging to a singleKafkaRecord
.- Since:
- 4.4.0
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description @Immutable @NotNull List<@NotNull KafkaHeader>
asList()
@Immutable @NotNull List<@NotNull KafkaHeader>
getAllForName(@NotNull String name)
@NotNull Optional<KafkaHeader>
getLast(@NotNull String name)
-
-
-
Method Detail
-
asList
@Immutable @NotNull @Immutable @NotNull List<@NotNull KafkaHeader> asList()
- Returns:
- All Kafka headers as a
List
. - Since:
- 4.4.0
-
getLast
@NotNull @NotNull Optional<KafkaHeader> getLast(@NotNull @NotNull String name)
- Parameters:
name
- The name of the Kafka header to get.- Returns:
- An
Optional
that contains the last Kafka header with the specified name. - Since:
- 4.4.0
-
getAllForName
@Immutable @NotNull @Immutable @NotNull List<@NotNull KafkaHeader> getAllForName(@NotNull @NotNull String name)
- Parameters:
name
- The name of the Kafka headers to get.- Returns:
- The values of the Kafka headers with the specified name.
- Since:
- 4.4.0
-
-