DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
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 | ||
|---|---|---|
| ||
// 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):
...