import org.apache.kafka.clients.consumer.*;
import org.apache.kafka.common.TopicPartition;
import java.util.*;

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "my-group");
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("enable.auto.commit", "false"); // Manual commit

KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Arrays.asList("topic"), new ConsumerRebalanceListener() {
    @Override
    public void onPartitionsRevoked(Collection<TopicPartition> partitions) {
        // Commit offsets before losing partitions
        commitOffsets(); // Custom method to commit processed offsets
    }

    @Override
    public void onPartitionsAssigned(Collection<TopicPartition> partitions) {
        // Restore state or seek to offsets
        /* warm-up: e.g., load local state for partitions */
    }
});

try {
    while (true) {
        ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
        // Process records
        consumer.commitAsync(); // Or commitSync for sync
    }
} finally {
    consumer.close();
}

public class Task180825 {
    static void method(Object x) {
        System.out.println("Object");
    }
    
    static void method(String x) {
        System.out.println("String");
    }
    
    static void method(Integer x) {
        System.out.println("Integer");
    }
    
    public static void main(String[] args) {
        method(null);
    }
}

public Person() {
    // Пусто, поля инициализируются значениями по умолчанию (null для объектов, 0 для чисел)
}

public class Person {
    private String name;
    private int age;

    // Конструктор с параметрами
    public Person(String name, int age) {
        this.name = name;
        this.age = age;
    }
}

При создании объекта new Person("Алексей", 35) конструктор присваивает значения полям.

public class Person {
    private String name;
    private int age;

    public Person(String name, int age) {
        this.name = name;  // this.name — поле класса, name — параметр
        this.age = age;
    }
}

Без this Java бы подумал, что name = name; — это присваивание параметра самому себе, что бесполезно.

public class Person {
    private String name;
    private int age;

    // Конструктор по умолчанию (без параметров)
    public Person() {
        this.name = "Неизвестный";
        this.age = 0;
    }

    // Конструктор с одним параметром
    public Person(String name) {
        this.name = name;
        this.age = 0;  // Возраст по умолчанию
    }

    // Конструктор с двумя параметрами
    public Person(String name, int age) {
        this.name = name;
        this.age = age;
    }

    // Вызов другого конструктора с помощью this()
    public Person(int age) {
        this("Неизвестный", age);  // Вызывает конструктор с двумя параметрами
    }
}

Теперь объекты можно создавать по-разному:Person p1 = new Person();               // Неизвестный, 0
Person p2 = new Person("Алексей");      // Алексей, 0
Person p3 = new Person("Алексей", 35);  // Алексей, 35
Person p4 = new Person(35);             // Неизвестный, 35

class A190825 {
    static {
        System.out.print("1");
    }
    
    {
        System.out.print("2");
    }
    
    public A190825() {
        System.out.print("3");
    }
}

class B190825 extends A190825 {
    static {
        System.out.print("4");
    }
    
    {
        System.out.print("5");
    }
    
    public B190825() {
        System.out.print("6");
    }
}

public class Task190825 {
    public static void main(String[] args) {
        new B190825();
        System.out.print("7");
        new B190825();
    }
}