public static void main()

in crossdc-consumer/src/main/java/org/apache/solr/crossdc/helpers/SendDummyUpdates.java [30:50]

• 21 lines of code
• 1 McCabe index (conditional complexity)

    public static void main(String[] args) {
        String TOPIC = "Trial";
        Properties properties = new Properties();
        properties.put("bootstrap.servers", "localhost:9092");
        properties.put("acks", "all");
        properties.put("retries", 3);
        properties.put("batch.size", 16384);
        properties.put("buffer.memory", 33554432);
        properties.put("linger.ms", 1);
        properties.put("key.serializer", StringSerializer.class.getName());
        properties.put("value.serializer", MirroredSolrRequestSerializer.class.getName());
        Producer<String, MirroredSolrRequest> producer = new KafkaProducer(properties);
        UpdateRequest updateRequest = new UpdateRequest();
        updateRequest.add("id", String.valueOf(System.currentTimeMillis()));
        MirroredSolrRequest mirroredSolrRequest = new MirroredSolrRequest(updateRequest);
        System.out.println("About to send producer record");
        producer.send(new ProducerRecord(TOPIC, mirroredSolrRequest));
        System.out.println("Sent producer record");
        producer.close();
        System.out.println("Closed producer");
    }