|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/RegisterControllerRecord.json
|
scanned
|
file
|
2.4 KB
|
RegisterControllerRecord.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/RemoveAccessControlEntryRecord.json
|
scanned
|
file
|
1.0 KB
|
RemoveAccessControlEntryRecord.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/RemoveDelegationTokenRecord.json
|
scanned
|
file
|
1.0 KB
|
RemoveDelegationTokenRecord.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/RemoveTopicRecord.json
|
scanned
|
file
|
1.1 KB
|
RemoveTopicRecord.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/RemoveUserScramCredentialRecord.json
|
scanned
|
file
|
1.1 KB
|
RemoveUserScramCredentialRecord.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/TopicRecord.json
|
scanned
|
file
|
1.1 KB
|
TopicRecord.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/UnfenceBrokerRecord.json
|
scanned
|
file
|
1.2 KB
|
UnfenceBrokerRecord.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/UnregisterBrokerRecord.json
|
scanned
|
file
|
1.1 KB
|
UnregisterBrokerRecord.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/UserScramCredentialRecord.json
|
scanned
|
file
|
1.6 KB
|
UserScramCredentialRecord.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/main/resources/common/metadata/ZkMigrationRecord.json
|
scanned
|
file
|
1.8 KB
|
ZkMigrationRecord.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/test/resources/log4j2.yaml
|
scanned
|
file
|
1.1 KB
|
log4j2.yaml
|
.yaml
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/NOTICE
|
scanned
|
file
|
886 bytes
|
NOTICE
|
|
|
text/plain
|
|
apache-2.0 AND cddl-1.0 AND epl-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/NOTICE-binary
|
scanned
|
file
|
26.2 KB
|
NOTICE-binary
|
|
verilog
|
text/plain
|
|
(apache-2.0 AND cddl-1.0 AND epl-2.0) AND apache-2.0 AND (epl-2.0 OR gpl-2.0 WITH classpath-exception-2.0) AND generic-export-compliance AND unknown-license-reference AND bsd-new AND epl-2.0 AND (apache-2.0 AND cpl-1.0) AND mit AND public-domain AND ((mit OR gpl-2.0-plus) AND mit AND gpl-1.0-plus) AND (cc0-1.0 AND mit) AND (bsd-new AND apache-2.0) AND w3c AND cddl-1.0 AND (cddl-1.0 OR gpl-2.0 WITH classpath-exception-2.0) AND (gpl-2.0 AND gpl-2.0 WITH classpath-exception-2.0) AND other-permissive AND (apache-2.0 AND bsd-new AND mit) AND cc-pd AND (unknown-license-reference AND bsd-new) AND (unknown-license-reference AND mit) AND (unknown-license-reference AND apache-2.0) AND apsl-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/config/kraft-log4j2.yaml
|
scanned
|
file
|
1.2 KB
|
kraft-log4j2.yaml
|
.yaml
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/config/kraft.properties
|
scanned
|
file
|
931 bytes
|
kraft.properties
|
.properties
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/.gitignore
|
scanned
|
file
|
6 bytes
|
.gitignore
|
|
|
text/plain
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/README.md
|
scanned
|
file
|
2.1 KB
|
README.md
|
.md
|
|
text/plain
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/errors/BufferAllocationException.java
|
scanned
|
file
|
1.1 KB
|
BufferAllocationException.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/errors/NotLeaderException.java
|
scanned
|
file
|
1.3 KB
|
NotLeaderException.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/ExternalKRaftMetrics.java
|
scanned
|
file
|
1.1 KB
|
ExternalKRaftMetrics.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/CloseListener.java
|
scanned
|
file
|
953 bytes
|
CloseListener.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/internals/RequestSendResult.java
|
scanned
|
file
|
1.3 KB
|
RequestSendResult.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/Isolation.java
|
scanned
|
file
|
888 bytes
|
Isolation.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/LogAppendInfo.java
|
scanned
|
file
|
955 bytes
|
LogAppendInfo.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/OffsetMetadata.java
|
scanned
|
file
|
946 bytes
|
OffsetMetadata.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/RaftMessageQueue.java
|
scanned
|
file
|
2.0 KB
|
RaftMessageQueue.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/java/org/apache/kafka/raft/SegmentPosition.java
|
scanned
|
file
|
1.1 KB
|
SegmentPosition.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/main/resources/common/message/QuorumStateData.json
|
scanned
|
file
|
1.8 KB
|
QuorumStateData.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/resources/log4j2.yaml
|
scanned
|
file
|
1.2 KB
|
log4j2.yaml
|
.yaml
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/README.md
|
scanned
|
file
|
14.3 KB
|
README.md
|
.md
|
|
text/plain
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/release/README.md
|
scanned
|
file
|
1.3 KB
|
README.md
|
.md
|
|
text/plain
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/release/requirements.txt
|
application-package
|
file
|
816 bytes
|
requirements.txt
|
.txt
|
|
text/plain
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/common/ClientIdAndBroker.java
|
scanned
|
file
|
1.4 KB
|
ClientIdAndBroker.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/deferred/DeferredEvent.java
|
scanned
|
file
|
1.1 KB
|
DeferredEvent.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/common/OffsetAndEpoch.java
|
scanned
|
file
|
1.1 KB
|
OffsetAndEpoch.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/common/serialization/MetadataParseException.java
|
scanned
|
file
|
1.3 KB
|
MetadataParseException.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/config/ConfigType.java
|
scanned
|
file
|
1.2 KB
|
ConfigType.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/fault/FaultHandlerException.java
|
scanned
|
file
|
1.5 KB
|
FaultHandlerException.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/fault/FaultHandler.java
|
scanned
|
file
|
1.5 KB
|
FaultHandler.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/mutable/BoundedListTooLongException.java
|
scanned
|
file
|
1.2 KB
|
BoundedListTooLongException.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/network/BrokerEndPoint.java
|
scanned
|
file
|
1.3 KB
|
BrokerEndPoint.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/network/ConnectionDisconnectListener.java
|
scanned
|
file
|
1.5 KB
|
ConnectionDisconnectListener.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/purgatory/DelayedOperationKey.java
|
scanned
|
file
|
969 bytes
|
DelayedOperationKey.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/quota/QuotaType.java
|
scanned
|
file
|
1.8 KB
|
QuotaType.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionErrorData.java
|
scanned
|
file
|
1.1 KB
|
PartitionErrorData.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionIdData.java
|
scanned
|
file
|
1.1 KB
|
PartitionIdData.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionIdLeaderEpochData.java
|
scanned
|
file
|
1.1 KB
|
PartitionIdLeaderEpochData.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionInfoData.java
|
scanned
|
file
|
1.0 KB
|
PartitionInfoData.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionStateData.java
|
scanned
|
file
|
1.1 KB
|
PartitionStateData.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionStateErrorData.java
|
scanned
|
file
|
1.2 KB
|
PartitionStateErrorData.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionStateSummaryData.java
|
scanned
|
file
|
1.2 KB
|
PartitionStateSummaryData.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PersisterParameters.java
|
scanned
|
file
|
990 bytes
|
PersisterParameters.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/share/persister/PersisterResult.java
|
scanned
|
file
|
983 bytes
|
PersisterResult.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/storage/log/UnexpectedAppendOffsetException.java
|
scanned
|
file
|
1.5 KB
|
UnexpectedAppendOffsetException.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/ThroughputThrottler.java
|
scanned
|
file
|
4.9 KB
|
ThroughputThrottler.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/timer/Timer.java
|
scanned
|
file
|
1.5 KB
|
Timer.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/timer/TimerTaskEntry.java
|
scanned
|
file
|
2.0 KB
|
TimerTaskEntry.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/server/util/timer/TimerTask.java
|
scanned
|
file
|
1.8 KB
|
TimerTask.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/timeline/Delta.java
|
scanned
|
file
|
1.1 KB
|
Delta.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/main/java/org/apache/kafka/timeline/Revertable.java
|
scanned
|
file
|
1.3 KB
|
Revertable.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/common/MetadataVersionTestUtils.java
|
scanned
|
file
|
1.1 KB
|
MetadataVersionTestUtils.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/java/org/apache/kafka/server/util/MockTime.java
|
scanned
|
file
|
1.7 KB
|
MockTime.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server-common/src/test/resources/log4j2.yaml
|
scanned
|
file
|
1.1 KB
|
log4j2.yaml
|
.yaml
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/ActionQueue.java
|
scanned
|
file
|
1.1 KB
|
ActionQueue.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/config/ClientQuotaManagerConfig.java
|
scanned
|
file
|
1.6 KB
|
ClientQuotaManagerConfig.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/config/ReplicationQuotaManagerConfig.java
|
scanned
|
file
|
2.1 KB
|
ReplicationQuotaManagerConfig.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/package-info.java
|
scanned
|
file
|
902 bytes
|
package-info.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/partition/AlterPartitionListener.java
|
scanned
|
file
|
1.3 KB
|
AlterPartitionListener.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/ProcessRole.java
|
scanned
|
file
|
1.1 KB
|
ProcessRole.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/quota/ControllerMutationQuota.java
|
scanned
|
file
|
1.5 KB
|
ControllerMutationQuota.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/quota/ThrottleCallback.java
|
scanned
|
file
|
931 bytes
|
ThrottleCallback.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/ReplicaState.java
|
scanned
|
file
|
1.1 KB
|
ReplicaState.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/fetch/DeliveryCountOps.java
|
scanned
|
file
|
1.0 KB
|
DeliveryCountOps.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/server/src/main/java/org/apache/kafka/server/share/ShareGroupListener.java
|
scanned
|
file
|
1.3 KB
|
ShareGroupListener.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/settings.gradle
|
scanned
|
file
|
4.0 KB
|
settings.gradle
|
.gradle
|
Groovy
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/resources/common/message/ShareSnapshotKey.json
|
scanned
|
file
|
1.2 KB
|
ShareSnapshotKey.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/resources/common/message/ShareSnapshotValue.json
|
scanned
|
file
|
2.6 KB
|
ShareSnapshotValue.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/resources/common/message/ShareUpdateKey.json
|
scanned
|
file
|
1.2 KB
|
ShareUpdateKey.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/share-coordinator/src/main/resources/common/message/ShareUpdateValue.json
|
scanned
|
file
|
2.3 KB
|
ShareUpdateValue.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/shell/src/test/resources/log4j2.yaml
|
scanned
|
file
|
1.0 KB
|
log4j2.yaml
|
.yaml
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/package-info.java
|
scanned
|
file
|
951 bytes
|
package-info.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteResourceNotFoundException.java
|
scanned
|
file
|
1.5 KB
|
RemoteResourceNotFoundException.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteStorageException.java
|
scanned
|
file
|
1.4 KB
|
RemoteStorageException.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteStorageNotReadyException.java
|
scanned
|
file
|
1.7 KB
|
RemoteStorageNotReadyException.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RetriableRemoteStorageException.java
|
scanned
|
file
|
1.6 KB
|
RetriableRemoteStorageException.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/BrokerReadyCallback.java
|
scanned
|
file
|
1.1 KB
|
BrokerReadyCallback.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/server/log/remote/quota/RLMQuotaManagerConfig.java
|
scanned
|
file
|
1.3 KB
|
RLMQuotaManagerConfig.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/server/log/remote/storage/CustomMetadataSizeLimitExceededException.java
|
scanned
|
file
|
928 bytes
|
CustomMetadataSizeLimitExceededException.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/AppendOrigin.java
|
scanned
|
file
|
1.7 KB
|
AppendOrigin.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/CompletedTxn.java
|
scanned
|
file
|
1.4 KB
|
CompletedTxn.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/CorruptIndexException.java
|
scanned
|
file
|
993 bytes
|
CorruptIndexException.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/EpochEntry.java
|
scanned
|
file
|
970 bytes
|
EpochEntry.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/IndexEntry.java
|
scanned
|
file
|
924 bytes
|
IndexEntry.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/IndexSearchType.java
|
scanned
|
file
|
895 bytes
|
IndexSearchType.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LeaderHwChange.java
|
scanned
|
file
|
913 bytes
|
LeaderHwChange.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogCleaningAbortedException.java
|
scanned
|
file
|
989 bytes
|
LogCleaningAbortedException.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogOffsetsListener.java
|
scanned
|
file
|
1.4 KB
|
LogOffsetsListener.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogOffsetSnapshot.java
|
scanned
|
file
|
1.3 KB
|
LogOffsetSnapshot.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/LogStartOffsetIncrementReason.java
|
scanned
|
file
|
1.3 KB
|
LogStartOffsetIncrementReason.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/main/java/org/apache/kafka/storage/internals/log/OffsetPosition.java
|
scanned
|
file
|
1.2 KB
|
OffsetPosition.java
|
.java
|
Java
|
text/plain
|
|
apache-2.0
|
|
|