Comment avez-vous effectué la mise à l'échelle des consommateurs Kafka ? Selon quels critères ?
Golang
Si la base de données n'est pas disponible et que vous faites une nouvelle tentative, ne traiterez-vous pas indéfiniment les mêmes messages ? Tous les 500 iront-ils en DLQ ?
Parlez-moi de vous.
Quand le ramasse-miettes est-il lancé ? Y a-t-il des points d'arrêt spéciaux à certains moments ?
Vous avez pris un lot de 500 messages de Kafka, mais vous ne pouvez pas les enregistrer dans la base de données. Que se passera-t-il ? Combien de temps peut-on traiter ces 500 messages ?
Quel algorithme utilise le ramasse-miettes en Go ? Comment fonctionne-t-il en général ?
Si nous ajoutons beaucoup de consommateurs, mais le retard de Kafka ne diminue pas, qu'est-ce que cela indique?
Quels moyens de synchronisation mentionnés avez-vous dû utiliser dans votre projet?
Comment la limite de taux a-t-elle été fixée ? Sur quoi était-elle basée et où a-t-elle été implémentée ? Qu'est-ce qui a été utilisé techniquement ?
Quels types d'interactions gRPC avez-vous utilisés ? Pouvez-vous les nommer ?
DevOps et analyste sont-ils la même personne ? Était-il un analyste de données ou un développeur full-stack, analyste système/affaires ?
Qu'est-ce qui vous intéresse à faire ? Est-ce que je comprends bien que vous avez mentionné la concurrence de Go en interne — cela concerne-t-il précisément l'intérêt pour le langage Go en raison de son modèle de concurrence ?
Comment exactement le message était-il marqué comme doublon ? Où cette marque avait-elle lieu ?
Quelles tâches serait-il intéressant de résoudre?