JAVA - Страница 1290

Я хочу позвонить в API для каждого сообщения, которое я потребляю из Kafka, чтобы сделать какой -то состояние Satherful
pipeline.apply( Read message ,
KafkaIO.read()
.withTopic( MyTopic )
.withCluster( MyCluster )
.withoutMetadata())
.apply(...

Я хотел бы прочитать пару строк из темы Kafka и создать файл AVRO.
У меня есть работа по частичным коду, который читает из темы Kafka и печатает на консоли. Кафка тема и отпечатки в консоли

public class BeamConsumer {

public static void...

У нас есть проект GCP DataFlow, который требует от нас отмены задания DataFlow.PipelineResult pipelineResult = pipeline.run();
result.cancel();

Тем не менее, мы не храним PipelinerSult, когда мы его создаем. Мне интересно, есть ли какие -либо...

У меня есть конвейер пучка, который считывает из таблицы MSSQL, используя простой запрос:
return SELECT
+ U.ID as userid,
+ U.firstname as firstname,
+ U.lastname as lastname,
+ email as email,
+ U.IP as ip
+ FROM users U WITH (NOLOCK)
+...

В настоящее время я работаю над потоковым конвейером в Beam Apache (v2.43), чтобы вставить данные в MongoDB. Он работает на DATAFLOW довольно хорошо, но я не могу контролировать количество соединений: в случае пика ввода (PubSub), DataFlow...

Я пытаюсь проанализировать durationstring = p10yt10m с использованием метода java.time.duration.parse (), но его неудача с «текстом не может быть проанализирована до продолжительности»
try {
String durationString = P5YT30M ;
Duration duration =...

Я новичок в Beam, и я не знаю, как я могу опубликовать пользовательское сообщение с помощью kafkaio.write.
Я должен использовать kafkaavroserializer.class в качестве сериализатора значения.
public void publish(CustomObject customObj) {...

Я использую Airflow для выполнения задач KubernetSpodoperator , которые запускают изображение приложения Java.
Приложение Java Использование Beam Dataflow.
my -пользовательские операторы воздушного потока наследуют kubernetepodoperator ....

У меня есть Pcollection kv, как это:
PCollection input = pipeline.apply(Create.of(
KV.of(0, new MyObject( A )),
KV.of(0, new MyObject( B )),
KV.of(1, new MyObject( C )),
KV.of(1, new MyObject( D )),
KV.of(2, new MyObject( E )),
KV.of(2, new...

Я очень новичок в концепциях CQRS и поиска событий, так что не будьте слишком тяжелыми (мой английский тоже не так хорош), так что извините, если есть какие -либо понимающие проблемы. Этот микросервис будет записан на Java с использованием Spring...

Когда я использую веб -сайт json Plactholder для вызова данных API, вызов API легко работает в моем приложении.
Однако, когда я пытаюсь использовать другие веб -сайты (например, GitHub или Pult Json -сайты), вызовы API не работают в моем приложении....

Это моя первая публикация библиотеки в Maven. Я выполнил все шаги в документах, но мое развертывание Maven не удается.

Подробнее здесь:

Итак, я в настоящее время пытаюсь объяснить моего друга, который начинает программирование обучения, какой -то код.
Я написал этот код для него в качестве примера, мой код дал мне неисправный результат, и я не понимаю, почему, поэтому я спросил...

Я пытаюсь использовать Google Distrose Container Base-Debian12 и копировать сверху Java, используя Docker Multisting Build. Я не хочу использовать Google Distrocebress с установленной Java напрямую как золотое изображение, так как я хочу управлять...

В моем приложении Android мне нужно подключиться к устройству через BLE и получить доступ к SD -карте на устройстве для чтения данных. Для этого мне нужно внедрить файловую систему, аналогичную FATFS в моем приложении Android для обработки файловых...

У меня есть критерий-строитель с объединением All (установленная операция), который я хочу обернуть в качестве объекта Select Select New)
cb.with(ChangesCTE.class)
.from(Changes.class)
.bind...
.where...
.groupBy...
.end()
.from(ChangesCTE.class,...

Я использую Liferay 6.2. Эта страница в настоящее время позволяет пользователям загружать файлы. Тем не менее, я больше не хочу, чтобы пользователи имели возможность загружать файлы и разрешали им только отправлять простой текст без каких -либо...

При отправке электронной почты из Java на Yahoo Mail ссылка внутри не работает.
Url не кликабель в Yahoo, в то время как в Gmail все в порядке.

Вот код, чтобы отправить почту:

MimeMessage mime = this.mailSender.createMimeMessage();...

Я построил жирную банку Spring 3.4, и когда я пытаюсь запустить ее, используя Spark Reading, я получаю следующую ошибку:
Exception in thread main java.lang.ExceptionInInitializerError
at...

После обновления моего проекта для использования новой RTC-двигателя и версии 2.9 пользовательского интерфейса я столкнулся с следующей ошибкой:
java.lang.NoClassDefFoundError: Failed resolution of: Lkotlin/enums/EnumEntriesKt;

Какой...

Я хотел бы представиться наилучшим образом, в том числе, чтобы разместить что -то, что может быть интересно для большинства разработчиков. С его помощью я могу показать вам его последнее изобретение под названием Saasberry, которое 3 из вас получит...

У меня есть приложение Java/Spring, где я использую WebSockets для синхронизации данных. У меня есть несколько методов розетки, где я обновляю определенные объекты. У меня также есть метод обновления, в котором я обновляю объект в зависимости от...

Описание проблемы
Со следующей настройкой
@Entity
public class ParentContainer {
@Id
@GeneratedValue
public Long id;
}

@Entity
public class Container1 extends ParentContainer{
@OneToMany
public Set parts;
}

@Entity
public class Container2...

Ошибка:

Приложение не удалось начать

Описание:
Была предпринята попытка вызвать метод, которого не существует. Попытка была предпринята из следующего места: org.springframework.orm.hibernate5.localsessionFactoryBuilder.ScanPackages...

Я пытаюсь проанализировать durationstring = p10yt10m с использованием метода java.time.duration.parse (), но его неудача с «текстом не может быть проанализирована до продолжительности»
try {
String durationString = P5YT30M ;
Duration duration =...