小编bos*_*sco的帖子

我对正在孵化的 Gradle 版本目录感到非常兴奋，并且一直在尝试它。I\xe2\x80\x99ve 发现我的信息可以在我的应用程序和 utility-lib 项目的脚本gradle/libs.versions.toml中访问。build.gradle.kts

但是，我无法使用该toml文件的内容buildSrc/build.gradle.kts或约定文件。

我可以构建的唯一方法是将依赖项硬编码到这些文件中，就像我在版本目录功能之前所做的那样。

在该buildSrc文件夹中，我创建了一个settings.gradle.kts文件并插入了 的dependencyResolutionManagement代码versionCatalogs，该代码指向与我的应用程序和 utility-lib 项目相同的文件。

根据 Gradle7文档，似乎可以与 和 模块共享版本目录\xe2\x80\xa6 I\xe2\x80\x99d如果可能的buildSrc话，希望能够推动它与 一起工作。buildSrc

这是一个简单的示例项目，我通过以下方式创建gradle init：my-version-catalog

感谢您的时间和帮助，

麦克风

不幸的是,我没有看到一个问题,问我到底需要什么,所以我决定发一个.

问题:我有一个加载iframe边栏的chrome扩展.在初始加载时,用户需要使用他们选择的Google帐户登录.此外,如果用户访问实际站点(在新选项卡中),则应向用户显示相同的身份验证流程(理想情况下).

我目前使用Google帐户选择器,当使用网站的iframe版本时,我遇到了一些问题,主要是:

拒绝在一个框架中显示" https://accounts.google.com/AccountChooser?continue=https://accounts.google ... t.com%26from_login%3D1%26as%3D473effc061cc82d5&btmpl = authsub&scc = 1&oauth = 1',因为它已设置'X-Frame-Options'到'DENY'.

总结一下,我需要的是:

• 一个auth流程,解决
  1. 通过iframe登录该网站
  2. 在新标签中登录该网站.
• 允许用户选择与帐户选择器类似的Google帐户的身份验证流程

我有下面的代码，但遇到了问题。我正在尝试将images表格包括在内...

order和之间已经存在关系images，但我不知道为什么它显示以下错误：

Unhandled rejection SequelizeDatabaseError: ER_BAD_FIELD_ERROR: Unknown column 'images.imageable' in 'on clause'

下面的代码：

models.Order.findOne({
    where: {
        id: req.params.orderId
    },
    attributes: ['id', 'comment', 'rating', 'orderDescription', 'userLat', 'userLng', 
                 'orderStatus', 'providerId', 'isUsingBalance', 'userId', 'serviceId', 
                 'createdAt', 'updatedAt', 'ticketNumber', 'orderScheduledDate', 'promoId', 'paymentMethodId',
        [sequelize.Sequelize.fn('date_format', sequelize.Sequelize.col('orderScheduledDate'), '%Y-%m-%D %h:%i'), 'orderScheduledDateToEdit']

    ],
    include: [{
            model: models.Comment,

            include: [{
                model: models.User,
                attributes: ['firstName', 'lastName', 'id']
            }]
        },
        {
            model: models.Provider,
            attributes: ['id', 'userId'],
            include: [{
                    model: models.User,
                    attributes: ['id', 'firstName', 'lastName', 'phoneNumber']
                },
                {
                    model: …

如何在spring-kafka版本中处理错误处理1.1.x？

正如我所看到的那样是在版本中引入的2.0......

我正在使用 springboot webclient 从远程服务器调用 rest api。第一个请求工作正常。如果我在一段时间后发出后续请求，服务器会抛出 500 服务器错误。我得到的错误是“onError(java.io.IOException:一个现有的连接被远程主机强行关闭)”。

我想通过禁用连接池来测试行为，因为我相信它使用以前的连接。你能帮我在创建 webclient 时如何禁用连接池吗？

TcpClient tcpClient = TcpClient.create()
        .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 30000)
        .option(ChannelOption.SO_KEEPALIVE, false)
        .doOnConnected(connection ->
                connection.addHandlerLast(new ReadTimeoutHandler(30))
                        .addHandlerLast(new WriteTimeoutHandler(30))
        );

ReactorClientHttpConnector httpConnector = new ReactorClientHttpConnector(HttpClient.from(tcpClient));

final WebClient webClient = WebClient
        .builder()
        .clientConnector(httpConnector)
        .baseUrl("http://customer.service.api.internal.cloud.qa.intranet.pagseguro.uol")
        .exchangeStrategies(strategies)
        .build()

我已经实现了FlinkKafkaConsumer消费来自卡夫卡主题的消息。除“组”和“主题”之外的唯一自定义设置是(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest")允许多次重新阅读相同的消息。它开箱即用，适合消费和逻辑。

现在FlinkKafkaConsumer已弃用，我想更新到它的后继者KafkaSource。

KafkaSource使用与我相同的参数进行初始化会FlinkKafkaConsumer按预期生成主题的读取，我可以通过打印流来验证这一点。反序列化和时间戳似乎工作正常。然而，窗口的执行尚未完成，因此不会产生任何结果。

我假设 中的某些默认设置KafkaSource与 的不同FlinkKafkaConsumer，但我不知道它们可能是什么。

KafkaSource -不工作

KafkaSource<TestData> source = KafkaSource.<TestData>builder()
     .setBootstrapServers(propertiesForKafka.getProperty("bootstrap.servers"))
     .setTopics(TOPIC)
     .setDeserializer(new CustomDeserializer())
     .setGroupId(GROUP_ID)
     .setStartingOffsets(OffsetsInitializer.earliest())
     .build();

DataStream<TestData> testDataStreamSource = env.fromSource(
     source,
     WatermarkStrategy. <
     TestData > noWatermarks(),
     "Kafka Source"
 );

卡夫卡消费者 -工作

（属性包含group.id、bootstrap.servers和zookeeper.connect）

propertiesForKafka.setProperty(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
FlinkKafkaConsumer<TestData> flinkKafkaConsumer = new FlinkKafkaConsumer(TOPIC, new CustomDeserializer(), propertiesForKafka);
DataStreamSource<TestData> testDataStreamSource = env.addSource(flinkKafkaConsumer)

两个流都使用相同的管道，如下所示

testDataStreamSource
    .assignTimestampsAndWatermarks(WatermarkStrategy.<TestData>forMonotonousTimestamps().withTimestampAssigner((event, timestamp) - …

我在 HTTP 中传递一个 JSON 数组对象POST作为

[{"level":"INFO","data": "Test 1"},{"level":"INFO","data": "Test 2"}]

该消息在 SumoLogic 中被视为 1 个对象/日志消息。我如何告诉 SumoLogic 将每个 JSON 对象视为一个独立的对象并显示 2 条日志消息而不是一条？