wpik

@Configuration
@EnableConfigurationProperties(ClassWithPropertiesToBeFilled.class)

wpik

    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]))$"
    );

wpik

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

wpik

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 {

wpik

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;

wpik

Based on: https://www.tutorialspoint.com/mongodb/mongodb_autoincrement_sequence.htm

1. Create collection to store sequence numbers: db.createCollection("counters");

2. Initialize the sequence: db.counters.insert({_id:"partySeq",sequence_value:-1});

3. Define function to get next sequence value:

   function getNextSequenceValue(sequenceName){
   

wpik

spring:
    cloud:
        stream:
            kafka:
                binder:
                    brokers: kafka-host:9092
                    configuration:
                        sasl:
                            mechanism: PLAIN
                        security:

wpik

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.converter.json.Jackson2ObjectMapperBuilder;

@Configuration
public class ObjectMapperConfig {

    @Bean
    public Jackson2ObjectMapperBuilder jacksonBuilder() {
        Jackson2ObjectMapperBuilder builder = new Jackson2ObjectMapperBuilder();

wpik

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.convert.converter.Converter;
import org.springframework.data.mongodb.core.convert.MongoCustomConversions;

import java.time.OffsetDateTime;
import java.time.ZoneOffset;
import java.util.List;

@Configuration

wpik

import org.springframework.boot.autoconfigure.kafka.ConcurrentKafkaListenerContainerFactoryConfigurer;
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.SeekToCurrentErrorHandler;

@Configuration
public class KafkaConfig {