|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/docs/streams/developer-guide/app-reset-tool.md
|
scanned
|
file
|
8.0 KB
|
app-reset-tool.md
|
.md
|
|
text/x-Algol68
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/util/Crc32CBenchmark.java
|
scanned
|
file
|
2.3 KB
|
Crc32CBenchmark.java
|
.java
|
Java
|
text/x-Algol68
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/metadata/src/test/java/org/apache/kafka/metadata/authorizer/StandardAclTest.java
|
scanned
|
file
|
4.1 KB
|
StandardAclTest.java
|
.java
|
Java
|
text/x-Algol68
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/raft/src/test/java/org/apache/kafka/raft/DynamicVotersTest.java
|
scanned
|
file
|
4.3 KB
|
DynamicVotersTest.java
|
.java
|
Java
|
text/x-Algol68
|
|
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/AbstractApiMessageSerde.java
|
scanned
|
file
|
5.4 KB
|
AbstractApiMessageSerde.java
|
.java
|
Java
|
text/x-Algol68
|
|
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/ConfigSynonym.java
|
scanned
|
file
|
2.7 KB
|
ConfigSynonym.java
|
.java
|
Java
|
text/x-Algol68
|
|
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/Json.java
|
scanned
|
file
|
4.2 KB
|
Json.java
|
.java
|
Java
|
text/x-Algol68
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/AbstractJoinIntegrationTest.java
|
scanned
|
file
|
14.2 KB
|
AbstractJoinIntegrationTest.java
|
.java
|
Java
|
text/x-Algol68
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/ResetPartitionTimeIntegrationTest.java
|
scanned
|
file
|
8.3 KB
|
ResetPartitionTimeIntegrationTest.java
|
.java
|
Java
|
text/x-Algol68
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/StateDirectoryIntegrationTest.java
|
scanned
|
file
|
11.8 KB
|
StateDirectoryIntegrationTest.java
|
.java
|
Java
|
text/x-Algol68
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/StreamTableJoinIntegrationTest.java
|
scanned
|
file
|
8.0 KB
|
StreamTableJoinIntegrationTest.java
|
.java
|
Java
|
text/x-Algol68
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/StreamTableJoinWithGraceIntegrationTest.java
|
scanned
|
file
|
5.4 KB
|
StreamTableJoinWithGraceIntegrationTest.java
|
.java
|
Java
|
text/x-Algol68
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/TableTableJoinIntegrationTest.java
|
scanned
|
file
|
58.3 KB
|
TableTableJoinIntegrationTest.java
|
.java
|
Java
|
text/x-Algol68
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/services/kafka/config_property.py
|
scanned
|
file
|
10.9 KB
|
config_property.py
|
.py
|
Python
|
text/x-Algol68
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/services/streams_property.py
|
scanned
|
file
|
1015 bytes
|
streams_property.py
|
.py
|
Python
|
text/x-Algol68
|
|
apache-2.0
|
|
|