|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/ShareGroupMetadataKey.json
|
scanned
|
file
|
1.0 KB
|
ShareGroupMetadataKey.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/ShareGroupMetadataValue.json
|
scanned
|
file
|
1.1 KB
|
ShareGroupMetadataValue.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/ShareGroupStatePartitionMetadataKey.json
|
scanned
|
file
|
1.0 KB
|
ShareGroupStatePartitionMetadataKey.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/ShareGroupStatePartitionMetadataValue.json
|
scanned
|
file
|
2.1 KB
|
ShareGroupStatePartitionMetadataValue.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/ShareGroupTargetAssignmentMemberKey.json
|
scanned
|
file
|
1.1 KB
|
ShareGroupTargetAssignmentMemberKey.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/ShareGroupTargetAssignmentMemberValue.json
|
scanned
|
file
|
1.3 KB
|
ShareGroupTargetAssignmentMemberValue.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/ShareGroupTargetAssignmentMetadataKey.json
|
scanned
|
file
|
1.0 KB
|
ShareGroupTargetAssignmentMetadataKey.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/ShareGroupTargetAssignmentMetadataValue.json
|
scanned
|
file
|
1.1 KB
|
ShareGroupTargetAssignmentMetadataValue.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupCurrentMemberAssignmentKey.json
|
scanned
|
file
|
1.1 KB
|
StreamsGroupCurrentMemberAssignmentKey.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupCurrentMemberAssignmentValue.json
|
scanned
|
file
|
3.0 KB
|
StreamsGroupCurrentMemberAssignmentValue.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupMemberMetadataKey.json
|
scanned
|
file
|
1.1 KB
|
StreamsGroupMemberMetadataKey.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupMemberMetadataValue.json
|
scanned
|
file
|
2.7 KB
|
StreamsGroupMemberMetadataValue.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupMetadataKey.json
|
scanned
|
file
|
1.0 KB
|
StreamsGroupMetadataKey.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupMetadataValue.json
|
scanned
|
file
|
1.9 KB
|
StreamsGroupMetadataValue.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupTargetAssignmentMemberKey.json
|
scanned
|
file
|
1.1 KB
|
StreamsGroupTargetAssignmentMemberKey.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupTargetAssignmentMemberValue.json
|
scanned
|
file
|
1.7 KB
|
StreamsGroupTargetAssignmentMemberValue.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupTargetAssignmentMetadataKey.json
|
scanned
|
file
|
1.0 KB
|
StreamsGroupTargetAssignmentMetadataKey.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupTargetAssignmentMetadataValue.json
|
scanned
|
file
|
1.1 KB
|
StreamsGroupTargetAssignmentMetadataValue.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupTopologyKey.json
|
scanned
|
file
|
1.0 KB
|
StreamsGroupTopologyKey.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/main/resources/common/message/StreamsGroupTopologyValue.json
|
scanned
|
file
|
4.0 KB
|
StreamsGroupTopologyValue.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/Assertions.java
|
scanned
|
file
|
16.9 KB
|
Assertions.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/AssignmentTestUtil.java
|
scanned
|
file
|
4.6 KB
|
AssignmentTestUtil.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/GroupSpecImplTest.java
|
scanned
|
file
|
4.4 KB
|
GroupSpecImplTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/OptimizedUniformAssignmentBuilderTest.java
|
scanned
|
file
|
26.6 KB
|
OptimizedUniformAssignmentBuilderTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/RangeAssignorTest.java
|
scanned
|
file
|
30.0 KB
|
RangeAssignorTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/RangeSetTest.java
|
scanned
|
file
|
6.0 KB
|
RangeSetTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/SimpleAssignorTest.java
|
scanned
|
file
|
35.4 KB
|
SimpleAssignorTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/assignor/UniformHeterogeneousAssignmentBuilderTest.java
|
scanned
|
file
|
24.5 KB
|
UniformHeterogeneousAssignmentBuilderTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/classic/ClassicGroupMemberTest.java
|
scanned
|
file
|
10.8 KB
|
ClassicGroupMemberTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/classic/ClassicGroupTest.java
|
scanned
|
file
|
61.8 KB
|
ClassicGroupTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupConfigManagerTest.java
|
scanned
|
file
|
3.6 KB
|
GroupConfigManagerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupConfigTest.java
|
scanned
|
file
|
14.6 KB
|
GroupConfigTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfigTest.java
|
scanned
|
file
|
23.0 KB
|
GroupCoordinatorConfigTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordHelpersTest.java
|
scanned
|
file
|
30.5 KB
|
GroupCoordinatorRecordHelpersTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordSerdeTest.java
|
scanned
|
file
|
9.9 KB
|
GroupCoordinatorRecordSerdeTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorServiceTest.java
|
scanned
|
file
|
277.8 KB
|
GroupCoordinatorServiceTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorShardTest.java
|
scanned
|
file
|
104.6 KB
|
GroupCoordinatorShardTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTestContext.java
|
scanned
|
file
|
72.2 KB
|
GroupMetadataManagerTestContext.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java
|
scanned
|
file
|
1.2 MB
|
GroupMetadataManagerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/metrics/GroupCoordinatorMetricsShardTest.java
|
scanned
|
file
|
2.2 KB
|
GroupCoordinatorMetricsShardTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/metrics/GroupCoordinatorMetricsTest.java
|
scanned
|
file
|
16.5 KB
|
GroupCoordinatorMetricsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/metrics/MetricsTestUtils.java
|
scanned
|
file
|
2.5 KB
|
MetricsTestUtils.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/MockPartitionAssignor.java
|
scanned
|
file
|
2.3 KB
|
MockPartitionAssignor.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/AssignmentTest.java
|
scanned
|
file
|
3.1 KB
|
AssignmentTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroupBuilder.java
|
scanned
|
file
|
4.1 KB
|
ConsumerGroupBuilder.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroupMemberTest.java
|
scanned
|
file
|
18.0 KB
|
ConsumerGroupMemberTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroupTest.java
|
scanned
|
file
|
85.3 KB
|
ConsumerGroupTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/consumer/CurrentAssignmentBuilderTest.java
|
scanned
|
file
|
47.5 KB
|
CurrentAssignmentBuilderTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/consumer/ResolvedRegularExpressionTest.java
|
scanned
|
file
|
2.1 KB
|
ResolvedRegularExpressionTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/MemberAssignmentImplTest.java
|
scanned
|
file
|
1.9 KB
|
MemberAssignmentImplTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupAssignmentBuilderTest.java
|
scanned
|
file
|
6.9 KB
|
ShareGroupAssignmentBuilderTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupBuilder.java
|
scanned
|
file
|
3.4 KB
|
ShareGroupBuilder.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupConfigTest.java
|
scanned
|
file
|
7.7 KB
|
ShareGroupConfigTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupMemberTest.java
|
scanned
|
file
|
7.6 KB
|
ShareGroupMemberTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupTest.java
|
scanned
|
file
|
18.9 KB
|
ShareGroupTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/SubscribedTopicMetadataTest.java
|
scanned
|
file
|
3.8 KB
|
SubscribedTopicMetadataTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/TargetAssignmentBuilderTest.java
|
scanned
|
file
|
36.6 KB
|
TargetAssignmentBuilderTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/TopicIdsTest.java
|
scanned
|
file
|
7.1 KB
|
TopicIdsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/UnionSetTest.java
|
scanned
|
file
|
3.9 KB
|
UnionSetTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/NetworkPartitionMetadataClientTest.java
|
scanned
|
file
|
52.0 KB
|
NetworkPartitionMetadataClientTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/NoOpPartitionAssignor.java
|
scanned
|
file
|
1.8 KB
|
NoOpPartitionAssignor.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetAndMetadataTest.java
|
scanned
|
file
|
6.3 KB
|
OffsetAndMetadataTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetExpirationConditionImplTest.java
|
scanned
|
file
|
2.9 KB
|
OffsetExpirationConditionImplTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/OffsetMetadataManagerTest.java
|
scanned
|
file
|
148.2 KB
|
OffsetMetadataManagerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/ShareGroupAutoOffsetResetStrategyTest.java
|
scanned
|
file
|
6.6 KB
|
ShareGroupAutoOffsetResetStrategyTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/assignor/GroupSpecImplTest.java
|
scanned
|
file
|
1.7 KB
|
GroupSpecImplTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/assignor/MockAssignorTest.java
|
scanned
|
file
|
8.7 KB
|
MockAssignorTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/assignor/ProcessStateTest.java
|
scanned
|
file
|
4.2 KB
|
ProcessStateTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/assignor/StickyTaskAssignorTest.java
|
scanned
|
file
|
79.7 KB
|
StickyTaskAssignorTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/CurrentAssignmentBuilderTest.java
|
scanned
|
file
|
43.6 KB
|
CurrentAssignmentBuilderTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/MockTaskAssignor.java
|
scanned
|
file
|
2.8 KB
|
MockTaskAssignor.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/StreamsCoordinatorRecordHelpersTest.java
|
scanned
|
file
|
39.5 KB
|
StreamsCoordinatorRecordHelpersTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/StreamsGroupBuilder.java
|
scanned
|
file
|
4.8 KB
|
StreamsGroupBuilder.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/StreamsGroupMemberTest.java
|
scanned
|
file
|
23.1 KB
|
StreamsGroupMemberTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/StreamsGroupTest.java
|
scanned
|
file
|
55.5 KB
|
StreamsGroupTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/StreamsTopologyTest.java
|
scanned
|
file
|
15.5 KB
|
StreamsTopologyTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/TargetAssignmentBuilderTest.java
|
scanned
|
file
|
33.0 KB
|
TargetAssignmentBuilderTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/TaskAssignmentTestUtil.java
|
scanned
|
file
|
5.1 KB
|
TaskAssignmentTestUtil.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/TasksTupleTest.java
|
scanned
|
file
|
7.3 KB
|
TasksTupleTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/TasksTupleWithEpochsTest.java
|
scanned
|
file
|
10.2 KB
|
TasksTupleWithEpochsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/TopicMetadataTest.java
|
scanned
|
file
|
2.8 KB
|
TopicMetadataTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/ChangelogTopicsTest.java
|
scanned
|
file
|
8.1 KB
|
ChangelogTopicsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/ConfiguredInternalTopicTest.java
|
scanned
|
file
|
3.0 KB
|
ConfiguredInternalTopicTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/ConfiguredSubtopologyTest.java
|
scanned
|
file
|
4.3 KB
|
ConfiguredSubtopologyTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/ConfiguredTopologyTest.java
|
scanned
|
file
|
5.0 KB
|
ConfiguredTopologyTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/CopartitionedTopicsEnforcerTest.java
|
scanned
|
file
|
9.6 KB
|
CopartitionedTopicsEnforcerTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/EndpointToPartitionsManagerTest.java
|
scanned
|
file
|
9.6 KB
|
EndpointToPartitionsManagerTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/InternalTopicManagerTest.java
|
scanned
|
file
|
8.5 KB
|
InternalTopicManagerTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/RepartitionTopicsTest.java
|
scanned
|
file
|
9.4 KB
|
RepartitionTopicsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/topics/TopicConfigurationExceptionTest.java
|
scanned
|
file
|
1.9 KB
|
TopicConfigurationExceptionTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/TopologyMetadataTest.java
|
scanned
|
file
|
4.5 KB
|
TopologyMetadataTest.java
|
.java
|
Java
|
text/x-c++
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/UtilsTest.java
|
scanned
|
file
|
9.5 KB
|
UtilsTest.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/group-coordinator/src/test/resources/log4j2.yaml
|
scanned
|
file
|
923 bytes
|
log4j2.yaml
|
.yaml
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/HEADER
|
scanned
|
file
|
754 bytes
|
HEADER
|
|
verilog
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/jmh-benchmarks/jmh.sh
|
scanned
|
file
|
1.4 KB
|
jmh.sh
|
.sh
|
Bash
|
text/x-shellscript
|
|
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/acl/AuthorizerBenchmark.java
|
scanned
|
file
|
9.9 KB
|
AuthorizerBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
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/acl/StandardAuthorizerUpdateBenchmark.java
|
scanned
|
file
|
4.9 KB
|
StandardAuthorizerUpdateBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
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/assignor/AssignorBenchmarkUtils.java
|
scanned
|
file
|
13.8 KB
|
AssignorBenchmarkUtils.java
|
.java
|
Java
|
text/x-java
|
|
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/assignor/ClientSideAssignorBenchmark.java
|
scanned
|
file
|
10.7 KB
|
ClientSideAssignorBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
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/assignor/CurrentAssignmentBuilderBenchmark.java
|
scanned
|
file
|
6.2 KB
|
CurrentAssignmentBuilderBenchmark.java
|
.java
|
Java
|
text/x-java
|
|
apache-2.0
|
|
|