DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
Current state: Under Discussion
Discussion thread: here [Change the link from the KIP proposal email archive to your own email thread]
JIRA: KAFKA-19448
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
...
| Code Block | ||
|---|---|---|
| ||
default Optional<CustomMetadata> copyLogSegmentData(RemoteLogSegmentMetadata remoteLogSegmentMetadata,
LogSegmentData logSegmentData,
LogConfig logConfig)
throws RemoteStorageException {
return copyLogSegmentData(remoteLogSegmentMetadata, logSegmentData);
}
default InputStream fetchLogSegment(RemoteLogSegmentMetadata remoteLogSegmentMetadata,
int startPosition,
LogConfig logConfig) throws RemoteStorageException {
return fetchLogSegment(remoteLogSegmentMetadata, startPosition);
}
default InputStream fetchLogSegment(RemoteLogSegmentMetadata remoteLogSegmentMetadata,
int startPosition,
int endPosition,
LogConfig logConfig) throws RemoteStorageException {
return fetchLogSegment(remoteLogSegmentMetadata, endPositionstartPosition, startPositionendPosition);
}
default InputStream fetchIndex(RemoteLogSegmentMetadata remoteLogSegmentMetadata,
IndexType indexType,
LogConfig logConfig) throws RemoteStorageException {
return fetchIndex(remoteLogSegmentMetadata, indexType);
}
default void deleteLogSegmentData(RemoteLogSegmentMetadata remoteLogSegmentMetadata,
LogConfig logConfig) throws RemoteStorageException {
deleteLogSegmentData(remoteLogSegmentMetadata);
} |
...