Как была реализована идемпотентность обработки событий в Kafka?
Embedded / IoT
Расскажите о себе и своём опыте работы
Есть ли вопросы по компании Bizon?
Что такое Fat JAR?
// Что выведет следующий код и почему? package main import "fmt" type Person struct { Name string } func changeName(person *Person) { person = &Person{ Name: "Alice", } } func main() { person := &Person{ Name: "Bob", } fmt.Println(person.Name) changeName(person) fmt.Println(person.Name) }
Расскажи о своём опыте работы — кто ты, где работал, чем занимался?
import javax.xml.bind.annotation.XmlAccessType; import javax.xml.bind.annotation.XmlAccessorType; import javax.xml.bind.annotation.XmlType; import java.io.*; @XmlAccessorType(XmlAccessType.PROPERTY) @XmlType(name = "Person", propOrder = { "name", "surname", "address", "phone", }) public class Person implements Serializable, Externalizable { private String name; private String surname; public String address; public String phone; public Person(String name, String surname) { this.name = name; this.surname = surname; } public String getName() { return name; } public String getSurname() { return surname; } @Override public int hashCode() { return 1; } @Override public boolean equals(Object o) { if (this == o) { return true; } if (o == null || getClass() != o.getClass()) { return false; } Person person = (Person) o; if (name != null ? !name.equals(person.name) : person.name != null) { return false; } if (surname != null ? !surname.equals(person.surname) : person.surname != null) { return false; } return true; } @Override public void writeExternal(ObjectOutput out) throws IOException { out.writeObject(name); out.writeObject(surname); out.writeObject(phone); out.writeObject(address); } @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { name = (String) in.readObject(); surname = (String) in.readObject(); address = (String) in.readObject(); phone = (String) in.readObject(); } }
// ... some code here? private static List<DocumentProvider> getDocumentProviders() { Reflections reflections = new Reflections(Main.class.getProtectionDomain().getCodeSource().getLocation()); Set<Class<?>> subTypes = reflections.get(SubTypes.of(DocumentProvider.class).asClass()); return subTypes.stream().map(subType -> { try { return (DocumentProvider) subType.getConstructor().newInstance(); } catch (Exception ex) { throw new RuntimeException(ex); } }).collect(Collectors.toList()); }
Какая сложность алгоритма бинарного поиска O?
hashCode() всегда возвращает 1 — что с этим не так? Будет ли HashMap работать корректно?
Что такое reverse proxy и с помощью чего можно его реализовать?
В топике с 6 партициями добавили ещё 6. Ключ — userID. Пойдёт ли сообщение с тем же ключом в ту же партицию?
Метод clone() — приходилось работать? Нравится ли обработка CloneNotSupportedException через throw new Error()?
Сколько времени займёт выполнение после оптимизации? Зависит ли это от количества потоков процессора (GOMAXPROCS)?
Как выполнить код после того, как Spring заинжектировал все зависимости бина?
Как решалась проблема гонки при параллельной обработке одной записи несколькими консьюмерами?
На основании каких полей нужно сделать hashCode, если equals нас устраивает?
Объясни логику возникновения дублей — механика процесса, где именно возникала проблема при обработке событий?
Писали ли кастомные Spring Boot Starters или Auto-configuration? В чём разница между Starter и Auto-configuration?
Как выполнить одинаковый код после инициализации для всех бинов, реализующих определённый интерфейс, не дублируя @PostConstruct в каждом?