wpik

Create collection to store sequence numbers: db.createCollection("counters");
Initialize the sequence: db.counters.insert({_id:"partySeq",sequence_value:-1});

Define function to get next sequence value:

function getNextSequenceValue(sequenceName){

	import org.springframework.boot.autoconfigure.kafka.ConcurrentKafkaListenerContainerFactoryConfigurer;
	import org.springframework.boot.context.properties.ConfigurationProperties;
	import org.springframework.context.annotation.Bean;
	import org.springframework.context.annotation.Configuration;
	import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;
	import org.springframework.kafka.core.ConsumerFactory;
	import org.springframework.kafka.listener.config.ContainerProperties;

	import java.util.regex.Pattern;

	package example;

	import com.google.common.net.InternetDomainName;
	import org.springframework.stereotype.Service;
	import org.springframework.web.util.UriComponentsBuilder;

	@Service
	public class TopDomainExtractor {
	public String getTopDomain(String requestUrl) {
	try {

	package example;

	import org.apache.http.HttpRequest
	import org.apache.http.HttpResponse
	import org.apache.http.ProtocolException
	import org.apache.http.client.RedirectStrategy
	import org.apache.http.client.methods.HttpUriRequest
	import org.apache.http.conn.DnsResolver
	import org.apache.http.impl.client.HttpClientBuilder
	import org.apache.http.protocol.HttpContext


	private static final Pattern RFC3339_TIMESTAMP_PATTERN = Pattern.compile(
	"^(\\d{4})-(0[1-9]\|1[0-2])-(0[1-9]\|[12][0-9]\|3[01])(?:T\|t)" +
	"([01][0-9]\|2[0-3]):([0-5][0-9]):([0-5][0-9]\|60)(\\.[0-9]+)?" +
	"(?:Z\|z\|(\\+\|-)([01][0-9]\|2[0-3]):([0-5][0-9]))$"
	);

	@Configuration
	@EnableConfigurationProperties(ClassWithPropertiesToBeFilled.class)