2017-10-04 1 views
1

私はカフカのトピックからメッセージを読むためにSpring Kafkaコンシューマを使用しています。私はこれらをOracle DBに残しています。 DB接続エラーが発生したときはいつでも、再試行したいと思います。Spring JDBCを使用してOracle DBに接続しています.JDBC接続の問題のみを再試行する必要がある場合に追加する必要がある例外クラスのリストは何ですか?Spring JDBC - カフカのコンシューマに対するリトライブル例外

private static Map<Class<? extends Throwable>, Boolean> retryableExceptions; 

static{ 
    retryableExceptions = new HashMap<>(); 
    retryableExceptions.put(Exception.class, true); 
} 
protected RetryPolicy retryPolicy() { 
     SimpleRetryPolicy policy = new SimpleRetryPolicy(maxRetryAttempts, retryableExceptions); 
     return policy; 
} 

答えて

1

私はあなただけでこれだけが必要だと思う:

/** 
* Data access exception thrown when a resource fails completely: 
* for example, if we can't connect to a database using JDBC. 
* 
* @author Rod Johnson 
* @author Thomas Risberg 
*/ 
@SuppressWarnings("serial") 
public class DataAccessResourceFailureException extends NonTransientDataAccessResourceException { 

限り、あなたはJDBC操作を実行するためにJdbcTemplateを使用して、接続している任意の低レベルのエラーがこのDataAccessResourceFailureExceptionまたはそのサブクラスに包まれています。

+0

ありがとうもう一度Artem! –

関連する問題