Визуализация привязки Spring Cloud Stream

Question

После того, как я включил привязки конечных точек привода, установив следующее свойство: management.endpoints.web.exposure.include=bindingsЯ должен увидеть привязки (потребительские) свойства.

Однако после того, как я добавил зависимость Spring Cloud Bus и также включил Spring Cloud Bus, я могу видеть только свойства привязок для springCloudBus, но не привязки, которые я создал в своем проекте.

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-bus-kafka</artifactId>
</dependency>

ВОПРОС: Как убедиться, что мы все еще можем видеть привязки, которые мы создали после включения весенней облачной шины?

Когда я установил spring.cloud.bus.enabled=falseЯ получил следующий результат

[
    {
        "name": "TestInput",
        "group": null,
        "pausable": true,
        "state": "running",
        "extendedInfo": {
            "bindingDestination": "KafkaConsumerDestination{consumerDestinationName='TestInput', partitions=1, dlqName='null'}",
            "ExtendedConsumerProperties": {
                "concurrency": 1,
                "instanceCount": 1,
                "maxAttempts": 3,
                "backOffInitialInterval": 1000,
                "backOffMaxInterval": 10000,
                "backOffMultiplier": 2,
                "extension": {
                    "ackEachRecord": false,
                    "autoRebalanceEnabled": true,
                    "autoCommitOffset": true,
                    "autoCommitOnError": null,
                    "startOffset": null,
                    "resetOffsets": false,
                    "enableDlq": false,
                    "dlqName": null,
                    "dlqProducerProperties": {
                        "bufferSize": 16384,
                        "compressionType": "none",
                        "sync": false,
                        "batchTimeout": 0,
                        "messageKeyExpression": null,
                        "headerPatterns": null,
                        "configuration": {},
                        "admin": {
                            "replicationFactor": null,
                            "replicasAssignments": {},
                            "configuration": {}
                        }
                    },
                    "recoveryInterval": 5000,
                    "trustedPackages": null,
                    "standardHeaders": "none",
                    "converterBeanName": null,
                    "idleEventInterval": 30000,
                    "configuration": {},
                    "admin": {
                        "replicationFactor": null,
                        "replicasAssignments": {},
                        "configuration": {}
                    }
                }
            }
        }
    },
    {
        "name": "TestInput2",
        "group": null,
        "pausable": true,
        "state": "running",
        "extendedInfo": {
            "bindingDestination": "KafkaConsumerDestination{consumerDestinationName='TestInput2', partitions=1, dlqName='null'}",
            "ExtendedConsumerProperties": {
                "concurrency": 1,
                "instanceCount": 1,
                "maxAttempts": 3,
                "backOffInitialInterval": 1000,
                "backOffMaxInterval": 10000,
                "backOffMultiplier": 2,
                "extension": {
                    "ackEachRecord": false,
                    "autoRebalanceEnabled": true,
                    "autoCommitOffset": true,
                    "autoCommitOnError": null,
                    "startOffset": null,
                    "resetOffsets": false,
                    "enableDlq": false,
                    "dlqName": null,
                    "dlqProducerProperties": {
                        "bufferSize": 16384,
                        "compressionType": "none",
                        "sync": false,
                        "batchTimeout": 0,
                        "messageKeyExpression": null,
                        "headerPatterns": null,
                        "configuration": {},
                        "admin": {
                            "replicationFactor": null,
                            "replicasAssignments": {},
                            "configuration": {}
                        }
                    },
                    "recoveryInterval": 5000,
                    "trustedPackages": null,
                    "standardHeaders": "none",
                    "converterBeanName": null,
                    "idleEventInterval": 30000,
                    "configuration": {},
                    "admin": {
                        "replicationFactor": null,
                        "replicasAssignments": {},
                        "configuration": {}
                    }
                }
            }
        }
    }
]

После того, как я установил spring.cloud.bus.enabled=true, Я могу видеть только свойства для SpringCloudBus

[
{
    "name": "springCloudBus",
    "group": null,
    "pausable": true,
    "state": "running",
    "extendedInfo": {
        "bindingDestination": "KafkaConsumerDestination{consumerDestinationName='springCloudBus', partitions=1, dlqName='null'}",
        "ExtendedConsumerProperties": {
            "concurrency": 1,
            "instanceCount": 1,
            "maxAttempts": 3,
            "backOffInitialInterval": 1000,
            "backOffMaxInterval": 10000,
            "backOffMultiplier": 2,
            "extension": {
                "ackEachRecord": false,
                "autoRebalanceEnabled": true,
                "autoCommitOffset": true,
                "autoCommitOnError": null,
                "startOffset": null,
                "resetOffsets": false,
                "enableDlq": false,
                "dlqName": null,
                "dlqProducerProperties": {
                    "bufferSize": 16384,
                    "compressionType": "none",
                    "sync": false,
                    "batchTimeout": 0,
                    "messageKeyExpression": null,
                    "headerPatterns": null,
                    "configuration": {},
                    "admin": {
                        "replicationFactor": null,
                        "replicasAssignments": {},
                        "configuration": {}
                    }
                },
                "recoveryInterval": 5000,
                "trustedPackages": null,
                "standardHeaders": "none",
                "converterBeanName": null,
                "idleEventInterval": 30000,
                "configuration": {},
                "admin": {
                    "replicationFactor": null,
                    "replicasAssignments": {},
                    "configuration": {}
                }
            }
        }
    }
}
]

Шаги для тиражирования:

1. Клонировать проект с https://github.com/HLTan94/SpringCloudStreamBindingsDemo

2. Задавать spring.cloud.bus.enabled

3. казнить curl -X GET http://localhost:9999/bindings

Answer 1

Я смог воспроизвести его и обнаружил, что это на самом деле ошибка с нашей стороны. Вы можете отслеживать это здесь. В любом случае у нас должен быть релиз сервиса к концу июля (то есть 2.0.2)