Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

The Time interface and Timer class in org.apache.kafka.common.utils are currently exposed through public APIs but not officially designated as public. Following KIP-1247 (Make Bytes public), these should be made officially public.

Code Block
languagejava
// KafkaStreams constructors (test-only usage)
public KafkaStreams(Topology topology, Properties props, Time time)

// NetworkClientUtils methods
public static boolean awaitReady(KafkaClient client, Node node, Time time, long timeoutMs)
public static ClientResponse sendAndReceive(KafkaClient client, ClientRequest request, Time time)


However, KafkaStreams exposes constructors accepting Time parameters that are only useful for testing, not production use. As noted in the KIP-1247 discussion, these test-only constructors should be deprecated before making Time the official public API.

Timer is returned by Time interface methods and users might interact with Timer's public methods. If Time becomes officially public, Timer must also be public as it is part of Time's contract.

Public Interfaces

New public APIs (4.4):

...