Path Lines of Code SolrAndKafkaIntegrationTest.java 183 crossdc-commons/src/main/java/org/apache/solr/crossdc/common/ConfigProperty.java 61 crossdc-commons/src/main/java/org/apache/solr/crossdc/common/CrossDcConf.java 5 crossdc-commons/src/main/java/org/apache/solr/crossdc/common/CrossDcConstants.java 4 crossdc-commons/src/main/java/org/apache/solr/crossdc/common/IQueueHandler.java 40 crossdc-commons/src/main/java/org/apache/solr/crossdc/common/KafkaCrossDcConf.java 190 crossdc-commons/src/main/java/org/apache/solr/crossdc/common/KafkaMirroringSink.java 91 crossdc-commons/src/main/java/org/apache/solr/crossdc/common/MirroredSolrRequest.java 59 crossdc-commons/src/main/java/org/apache/solr/crossdc/common/MirroredSolrRequestSerializer.java 100 crossdc-commons/src/main/java/org/apache/solr/crossdc/common/MirroringException.java 15 crossdc-commons/src/main/java/org/apache/solr/crossdc/common/RequestMirroringSink.java 4 crossdc-commons/src/main/java/org/apache/solr/crossdc/common/ResubmitBackoffPolicy.java 5 crossdc-commons/src/main/java/org/apache/solr/crossdc/common/SensitivePropRedactionUtils.java 29 crossdc-commons/src/main/java/org/apache/solr/crossdc/common/SolrExceptionUtil.java 13 crossdc-consumer/src/main/java/org/apache/solr/crossdc/consumer/BlockingQueue.java 17 crossdc-consumer/src/main/java/org/apache/solr/crossdc/consumer/Consumer.java 97 crossdc-consumer/src/main/java/org/apache/solr/crossdc/consumer/KafkaCrossDcConsumer.java 280 crossdc-consumer/src/main/java/org/apache/solr/crossdc/consumer/PartitionManager.java 96 crossdc-consumer/src/main/java/org/apache/solr/crossdc/helpers/SendDummyUpdates.java 32 crossdc-consumer/src/main/java/org/apache/solr/crossdc/messageprocessor/MessageProcessor.java 11 crossdc-consumer/src/main/java/org/apache/solr/crossdc/messageprocessor/SolrMessageProcessor.java 251 crossdc-consumer/src/resources/configs/cloud-minimal/conf/schema.xml 34 crossdc-consumer/src/resources/configs/cloud-minimal/conf/solrconfig.xml 65 crossdc-consumer/src/resources/log4j2.xml 23 crossdc-producer/src/main/java/org/apache/solr/update/processor/KafkaRequestMirroringHandler.java 25 crossdc-producer/src/main/java/org/apache/solr/update/processor/MirroringException.java 15 crossdc-producer/src/main/java/org/apache/solr/update/processor/MirroringUpdateProcessor.java 278 crossdc-producer/src/main/java/org/apache/solr/update/processor/MirroringUpdateRequestProcessorFactory.java 170 crossdc-producer/src/main/java/org/apache/solr/update/processor/RequestMirroringHandler.java 5 encryption/src/main/java/org/apache/solr/encryption/CommitUtil.java 17 encryption/src/main/java/org/apache/solr/encryption/EncryptionDirectory.java 206 encryption/src/main/java/org/apache/solr/encryption/EncryptionDirectoryFactory.java 62 encryption/src/main/java/org/apache/solr/encryption/EncryptionMergePolicy.java 52 encryption/src/main/java/org/apache/solr/encryption/EncryptionMergePolicyFactory.java 17 encryption/src/main/java/org/apache/solr/encryption/EncryptionRequestHandler.java 250 encryption/src/main/java/org/apache/solr/encryption/EncryptionUpdateHandler.java 39 encryption/src/main/java/org/apache/solr/encryption/EncryptionUtil.java 73 encryption/src/main/java/org/apache/solr/encryption/KeyManager.java 14 encryption/src/main/java/org/apache/solr/encryption/crypto/AesCtrEncrypter.java 7 encryption/src/main/java/org/apache/solr/encryption/crypto/AesCtrEncrypterFactory.java 6 encryption/src/main/java/org/apache/solr/encryption/crypto/AesCtrUtil.java 37 encryption/src/main/java/org/apache/solr/encryption/crypto/CipherAesCtrEncrypter.java 102 encryption/src/main/java/org/apache/solr/encryption/crypto/DecryptingIndexInput.java 193 encryption/src/main/java/org/apache/solr/encryption/crypto/EncryptingIndexOutput.java 96 encryption/src/main/java/org/apache/solr/encryption/crypto/LightAesCtrEncrypter.java 158 encryption/src/main/java/org/apache/solr/encryption/crypto/SecureRandomProvider.java 10 encryption/src/main/java/org/apache/solr/update/DirectUpdateHandler2Copy.java 829 log4j2.xml 44