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