本文整理了Java中org.apache.kafka.connect.errors.ConnectException.getMessage()
方法的一些代码示例,展示了ConnectException.getMessage()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ConnectException.getMessage()
方法的具体详情如下:
包路径:org.apache.kafka.connect.errors.ConnectException
类名称:ConnectException
方法名:getMessage
暂无
代码示例来源:origin: qubole/streamx
public void close(Collection<TopicPartition> partitions) {
// Close any writers we have. We may get assigned the same partitions and end up duplicating
// some effort since we'll have to reprocess those messages. It may be possible to hold on to
// the TopicPartitionWriter and continue to use the temp file, but this can get significantly
// more complex due to potential failures and network partitions. For example, we may get
// this close, then miss a few generations of group membership, during which
// data may have continued to be processed and we'd have to restart from the recovery stage,
// make sure we apply the WAL, and only reuse the temp file if the starting offset is still
// valid. For now, we prefer the simpler solution that may result in a bit of wasted effort.
for (TopicPartition tp: assignment) {
try {
topicPartitionWriters.get(tp).close();
} catch (ConnectException e) {
log.error("Error closing writer for {}. Error: {}", tp, e.getMessage());
} finally {
topicPartitionWriters.remove(tp);
}
}
}
代码示例来源:origin: salesforce/mirus
@Override
public void run() {
logger.info("Starting a task monitor thread...");
Runtime.getRuntime().addShutdownHook(shutdownHook);
while (!shutdown.get()) {
try {
herder.connectors(this::onConnectors);
try {
boolean isCountZero = countDownLatch.await(pollingIntervalMillis, TimeUnit.MILLISECONDS);
shutdown.set(isCountZero);
} catch (InterruptedException e) {
logger.info("Exiting TaskMonitor thread...");
}
} catch (ConnectException e) {
logger.warn(
"TaskMonitor thread will continue to execute despite exception. Caught exception: {}",
e.getMessage());
}
}
}
内容来源于网络,如有侵权,请联系作者删除!