public class RestClient extends Object implements Closeable
Constructor and Description |
---|
RestClient(Map<String,?> configs) |
RestClient(Map<String,?> configs,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.kafka.common.security.oauthbearer.OAuthBearerToken |
login() |
org.apache.kafka.common.security.oauthbearer.OAuthBearerToken |
login(HttpCredentialProvider credentialProvider) |
org.apache.kafka.common.security.oauthbearer.OAuthBearerToken |
login(String userInfo) |
RestRequest |
newRequest(String path) |
<T> T |
sendRequest(RestRequest request) |
void |
setCredentialProvider(HttpCredentialProvider credentialProvider) |
public void setCredentialProvider(HttpCredentialProvider credentialProvider)
public RestRequest newRequest(String path)
public org.apache.kafka.common.security.oauthbearer.OAuthBearerToken login() throws org.apache.kafka.common.errors.AuthenticationException
org.apache.kafka.common.errors.AuthenticationException
public org.apache.kafka.common.security.oauthbearer.OAuthBearerToken login(String userInfo)
public org.apache.kafka.common.security.oauthbearer.OAuthBearerToken login(HttpCredentialProvider credentialProvider)
public <T> T sendRequest(RestRequest request) throws RestClientException, URISyntaxException
public void close()
close
in interface Closeable
close
in interface AutoCloseable