import org.apache.kafka.clients.producer.*;
import java.util.Properties;

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

KafkaProducer<String, String> producer = new KafkaProducer<>(props);
ProducerRecord<String, String> record = new ProducerRecord<>("my-topic", "key", "value");
producer.send(record);
producer.close();

import org.apache.kafka.clients.consumer.*;
import java.util.Properties;
import java.util.Collections;

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

KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Collections.singleton("my-topic"));
ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(1000));
for (ConsumerRecord<String, String> record : records) {
    System.out.println(record.value());
}
consumer.close();

import java.util.Random;
import java.util.concurrent.ThreadLocalRandom;

public class Task120825 {
    public static void main(String[] args) {
        Random r1 = new Random(42);
        Random r2 = new Random(42);
        
        System.out.println(r1.nextInt(100) == r2.nextInt(100));
        
        ThreadLocalRandom tl1 = ThreadLocalRandom.current();
        ThreadLocalRandom tl2 = ThreadLocalRandom.current();
        
        System.out.println(tl1.nextInt(100) == tl2.nextInt(100));
    }
}

break;

метка: {
    // Цикл
    break метка;
}

continue;

метка: {
    // Цикл
    continue метка;
}

имяМетки: for (...) {
    // Код
    break имяМетки; // или continue имяМетки
}

int i = 1;
while (i <= 5) {
    System.out.println(i);
    if (i > 3) {
        break;
    }
    i++;
}

1
2
3
4

for (int i = 1; i <= 5; i++) {
    if (i % 2 == 0) {
        continue;
    }
    System.out.println(i);
}

1
3
5

outer: for (int i = 1; i <= 3; i++) {
    for (int j = 1; j <= 3; j++) {
        if (j == 2) {
            break outer; // Прерывает внешний цикл
        }
        System.out.println("i=" + i + ", j=" + j);
    }
}

i=1, j=1

outer: for (int i = 1; i <= 3; i++) {
    for (int j = 1; j <= 3; j++) {
        if (j == 2) {
            continue outer; // Переходит к следующей итерации внешнего цикла
        }
        System.out.println("i=" + i + ", j=" + j);
    }
}

i=1, j=1
i=2, j=1
i=3, j=1

int[] numbers = {1, 2, 3, 4, 5};
int target = 3;
boolean found = false;
for (int num : numbers) {
    if (num == target) {
        found = true;
        break;
    }
}
System.out.println("Найдено: " + found);

int sum = 0;
for (int i = -2; i <= 3; i++) {
    if (i <= 0) {
        continue;
    }
    sum += i;
}
System.out.println("Сумма: " + sum); // 1 + 2 + 3 = 6

int[] numbers = {1, 2, 3, 4, 5};
int target = 3;
boolean found = false;
for (int num : numbers) {
    if (num == target) {
        found = true;
        break;
    }
}
System.out.println("Найдено: " + found);

int sum = 0;
for (int i = -2; i <= 3; i++) {
    if (i <= 0) {
        continue;
    }
    sum += i;
}
System.out.println("Сумма: " + sum); // 1 + 2 + 3 = 6

int[][] matrix = {{1, 2}, {3, 4}};
outer: for (int row = 0; row < matrix.length; row++) {
    for (int col = 0; col < matrix[row].length; col++) {
        if (matrix[row][col] == 3) {
            System.out.println("Найдено в строке " + row + ", столбце " + col);
            break outer;
        }
    }
}

while (true) {
    if (condition) break;
}

loop:
if condition goto end
goto loop
end:

public class Task130825 {
    public static void main(String[] args) {
        int count = 0;
        outer:
        for (int i = 0; i < 3; i++) {
            inner:
            for (int j = 0; j < 3; j++) {
                if (i == 1 && j == 1) {
                    break outer;
                }
                count++;
            }
        }
        System.out.println(count);
    }
}

import org.apache.kafka.clients.producer.*;
import java.util.Properties;

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("acks", "all");
props.put("enable.idempotence", "true");
props.put("transactional.id", "order-tx-1");

try (KafkaProducer<String, String> producer = new KafkaProducer<>(props)) {
    producer.initTransactions();
    producer.beginTransaction();
    ProducerRecord<String, String> record = new ProducerRecord<>("orders", "key", "value");
    producer.send(record);
    producer.commitTransaction();
} catch (ProducerFencedException e) {
    // Handle fencing, e.g., abort and reinitialize
} catch (KafkaException e) {
    // Abort on error
    producer.abortTransaction();
}