[Netflix API] Watched movies don't show up in Netflix web app's "Viewing activity"

Movies/episodes watched using plugin.video.netflix don't show up in in the "Viewing activity" log in Netflix' web app (https://www.netflix.com/viewingactivity).
I know nothing about the Netflix protocols, so I'm not sure if this is fixable at all.

 I hope to have some more time this month to work on this. Most probably this is done via a separate call (I suspect the call to the "log" endpoint to be responsible for this).

Further investigation has shown that it´s way harder than initially thought to implement this.
The Netflix web ui uses an endpoint https://www.netflix.com/ichnaea/log that communicates the current watch state (and watch position) to their servers.
The request payload looks like this:
{"events":[{"category":"uiView","modalView":"homeScreen","kids":false,"data":{"view":"bob"},"dataContext":{"trackId":15035895,"videoId":70158329,"row":2,"rank":0,"requestId":"5a16eaa6-82d2-462f-9a62-90c56cb609ef-49931493"},"type":"sessionEnded","name":"impression.ended","sessionName":"impression","time":1507556637001,"id":"150755663728737368","sessionId":"15075566368957094","duration":969,"activeSessions":[["uiQOE","NavigationLevel","150252422946357344"],["uiAction","renoRefresh","150693726411601076"],["uiQOE","appSession","150755662674435967"],["uiQOE","userSession","150755662622682232"],["uiAction","startPlay","150755663675012803"]],"sequence":"2008"},{"category":"uiAction","modalView":"homeScreen","kids":false,"data":{},"dataContext":{},"type":"sessionStarted","name":"navigate.started","sessionName":"navigate","time":1507556637091,"id":"150755663793271948","sessionId":"150755663756288523","sessionKey":["uiAction","navigate","150755663756288523"],"activeSessions":[["uiQOE","NavigationLevel","150252422946357344"],["uiAction","renoRefresh","150693726411601076"],["uiQOE","appSession","150755662674435967"],["uiQOE","userSession","150755662622682232"],["uiAction","startPlay","150755663675012803"],["uiAction","navigate","150755663756288523"]],"sequence":"2009"},{"category":"uiQOE","modalView":"playback","kids":false,"data":{"sourceModalView":"homeScreen"},"type":"event","name":"uiModalViewChanged","time":1507556637091,"id":"150755663733310440","activeSessions":[["uiQOE","NavigationLevel","150252422946357344"],["uiAction","renoRefresh","150693726411601076"],["uiQOE","appSession","150755662674435967"],["uiQOE","userSession","150755662622682232"],["uiAction","startPlay","150755663675012803"],["uiAction","navigate","150755663756288523"]],"sequence":"2010"},{"category":"www","modalView":"playback","kids":false,"data":{"kids":false,"reason":"success","ppmID":"c93be713-8f2a-c75e-021e-d71aeeffca8f","ppmGUID":"6430c02e-e267-8ee2-ff15-cd4f5aaf7dc5","ppmInput":{"event":"ScrollVertical","content":{"ux":"watch","lolomos":[]}},"ppmOutput":[{"viewableId":70158329,"priority":1,"firstTimeAdded":1507556636050,"trackId":15035895},{"viewableId":70142441,"priority":2,"firstTimeAdded":1507556631220,"trackId":14170286},{"viewableId":80126024,"priority":3,"firstTimeAdded":1507556631220,"trackId":14170286},{"viewableId":70223362,"priority":4,"firstTimeAdded":1507556631867,"trackId":14191787},{"viewableId":80081537,"priority":5,"firstTimeAdded":1507556628094,"trackId":200256506},{"delta":0}],"uiEventDuration":0.09000000000014552,"ppmEventDuration":0.07999999999992724},"dataContext":{},"type":"sessionEnded","name":"playPrediction.ended","sessionName":"playPrediction","time":1507556637302,"id":"150755663729633920","sessionId":"150755663773874333","duration":0,"activeSessions":[["uiQOE","NavigationLevel","150252422946357344"],["uiAction","renoRefresh","150693726411601076"],["uiQOE","appSession","150755662674435967"],["uiQOE","userSession","150755662622682232"],["uiAction","startPlay","150755663675012803"],["uiAction","navigate","150755663756288523"]],"sequence":"2011"},{"category":"www","modalView":"playback","kids":false,"data":{"kids":false,"config":{"autoPlay":true,"initParams":{"playableId":70178007,"episodeId":70178007,"backToBrowsingUrl":"/title/70178007","trackingId":15035895,"signoutUrl":"/SignOut?lnkctr=mL","referrerIsNetflix":true,"assistiveAudioPreferred":false,"pinConfig":{"adultVerificationUrl":"https://www.netflix.com/verifyage?videoid=70178007","isEnabled":true,"resetUrl":"https://www.netflix.com/player/pinreset","pinResetOnNonPinContent":false,"isAdultVerified":true,"apiEndpoint":"https://www.netflix.com/api/shakti/f491d84f/pin/service"},"preReleasePinRequiredById":{},"nccpAppId":"150755662674435967","appId":"150755662674435967","nccpSessionId":"150755662622682232","sessionId":"150755662622682232","environment":"prod","preferredLanguages":"de-DE","supportPhoneNumber":"0800-724-0963","errorSupportUrls":{"F7031-1102":"25078","H7053-1803":"14452","H7111-1101":"14563","H7354":"12993","H7361-1253-80070005":"32876","M7355-1203":"22952","M7357-1003":"14759","C7357-1003":"14759","M7357-1269":"14759","C7357-1269":"14759","M7701-1003":"27451","M7702-1003":"30321","S7354":"25711","S7363-1266-0000230D":"25704","S7363-1266-00002E3F":"32701","F7053-1803":"32660","F7701-1003":"32661","S7363-1266-48444350":"22497","O7702-1003":"40838"},"chromeVersion":"Chrome 61.0.3163","windowScaling":true,"uimode":"akira","apiUrl":"https://www.netflix.com/api/shakti/f491d84f","postPlayApiRevision":"","preserveLastFrame":true,"mdx2Enabled":true,"hideSupportUrl":false,"uiTrackingEnabled":true,"uiTrackingEndpoint":"/uitracking/users/presentationtracking","uiVersion":"akira","enableTrickPlay":true,"breakOnError":false,"disableVideoRightClickMenu":false,"renderTimedText":true,"postPlayBaseUrl":"https://www.netflix.com/api/shakti/f491d84f/postplay","reportAProblemEndpoint":"https://www.netflix.com/api/shakti/f491d84f/reportproblem","reportProblemEnabled":true,"metadataBaseServer":"https://www.netflix.com/api/shakti/f491d84f","akiraMetadataStrategy":"shakti","forceCCPaint":true,"requestFromNetflix":false,"timedTextStyleDefaults":{"backgroundColor":null,"backgroundOpacity":"OPAQUE","characterColor":"WHITE","characterEdgeAttributes":"DROP_SHADOW","characterEdgeColor":"BLACK","characterOpacity":"OPAQUE","characterSize":"MEDIUM","characterStyle":"PROPORTIONAL_SANS_SERIF","windowColor":null,"windowOpacity":"OPAQUE"},"timedTextStyleOverrides":{"backgroundColor":null,"backgroundOpacity":null,"characterColor":null,"characterEdgeAttributes":null,"characterEdgeColor":null,"characterOpacity":null,"characterSize":null,"characterStyle":null,"windowColor":null,"windowOpacity":null},"useStarRatings":false,"useThumbRatings":true,"largeDisplayDimensionThreshold":{"height":900,"width":1600},"maxAutoPlaySeconds":15,"autoplayInterrupterTimestamp":120,"ignoreUserActivity":false,"webkitDecodedFrameCountIncorrectlyReported":true,"secureUrls":true,"playerUpsellEnabled":true,"skipCreditsEnabled":true,"skipCreditsDisplayDuration":6000,"bookmarkByMovieId":{},"preciseSeeking":true,"focusPlayerWrapperAfterControlClick":false,"limitedSVGSupport":false,"metadataRequestFormat":"NOFALCOR","maxTrackLengthUI":7,"mdxInitTimeout":120000,"castSdkConnectTimeout":20000,"mdxConnectionTimeout":60000,"castSdkDisconnectTimeout":60000,"uiContextConfig_motionBillboard":{"preferredEngine":"cadmium"},"uiContextConfig_bigRow":{"preferredEngine":"cadmium"},"feedback":{"minChars":75,"maxChars":1000},"resetControlFocusAfterClick":true,"prepare":true,"browserInfo":{"name":"Chrome","version":"61.0.3163","major":61,"os":{"name":"Mac OS X","fullName":"Mac OS X","version":"10.12.6"},"isFirefox":false,"isSafari":false,"isIE":false,"isEdge":false,"isChrome":true,"isOpera":false,"isWindows":false,"isMac":true,"isChromeOS":false,"isLinux":false,"isAndroid":false,"isIOS":false,"isIOSGT91":false,"isWindowsPhone":false,"isMobile":false,"isWindowsVista":false,"isWindowsXP":false,"isWindows7":false,"isWindows8":false,"isWindows10":false,"originallyIdentifiedAsAppleMail":false,"features":{"webp":true,"es2015":true,"maybeSupportsHTML5withDRM":true,"maybeSupportsSL":false,"maybeSupportsHTML5":true,"drmSystem":"widevine"},"specialFlags":{},"esnPrefix":"NFCDCH-MC-","_rawResult":{"family":"Chrome","major":"61","minor":"0","patch":"3163","device":{"family":"Other","major":"0","minor":"0","patch":"0"},"os":{"family":"Mac OS X","major":"10","minor":"12","patch":"6"}}},"playdataPrepareRequest":false,"notifyOpenConnectBlackBox":true,"histAggregationTimeSpanInSeconds":600,"secureStopEnabled":false,"mslEndpoint":"https://www.netflix.com/api/msl/","congestionServiceApiEndpoint":"https://www.netflix.com/api/cbp/html5player/congestion","pingOnConnectTimeout":true,"endpoint":true,"enableCongestionService":false,"usePerformanceApi":"false","downloadReportDenominator":10,"prepareStrategy":"ppm","prepareManifestCacheMaxCount":50,"prepareLdlCacheMaxCount":30,"ppmConfig":{"holdDuration":300000,"colEpisodeList":1,"rowFirst":1,"colFirst":1,"rowScroll":1,"colScroll":3,"rowScrollHorizontal":3,"searchTop":1,"cwFirst":2,"gridFirst":0,"gridScroll":0,"genre":2},"supportPreviewContent":true,"useSetServerCertificateApi":true,"ftlEnabled":true,"ftlEndpoint":"https://api-global.netflix.com/ftl/probe","esn":"NFCDCH-MC-CT75XQ4ETW768HFFJ3F1QE69CHYG8F","endPtsByViewableId":{"70178007":2651000}},"videoId":70178007,"shouldCloseAllPlayers":true,"creationParams":{"trackingId":15035895,"uiLabel":"standard","sessionParams":{"uiplaycontext":{"rank":"0","request_id":"5a16eaa6-82d2-462f-9a62-90c56cb609ef-49931493","row":"2","track_id":15035895},"isUIAutoPlay":false,"supportsWatermark":true,"supportsPreReleasePin":true},"authParams":{"pinCapableClient":true},"uiPlayStartTime":1507556636195,"disableTrackStickiness":false},"playerState":{"volume":1,"muted":false}},"xid":15075566368841,"reason":"VideoSession::createPlayerSafely"},"dataContext":{},"type":"sessionEnded","name":"playerCreate.ended","sessionName":"playerCreate","time":1507556637708,"id":"15075566376233411","sessionId":"150755663768087011","duration":0,"activeSessions":[["uiQOE","NavigationLevel","150252422946357344"],["uiAction","renoRefresh","150693726411601076"],["uiQOE","appSession","150755662674435967"],["uiQOE","userSession","150755662622682232"],["uiAction","startPlay","150755663675012803"],["uiAction","navigate","150755663756288523"]],"sequence":"2012"},{"category":"uiAction","kids":false,"modalView":"playback","data":{"reason":"success","videoId":70178007,"xid":15075566368841},"dataContext":{"trackId":15035895},"type":"sessionEnded","name":"startPlay.ended","sessionName":"startPlay","time":1507556638519,"id":"150755663817893240","sessionId":"150755663675012803","duration":2321,"activeSessions":[["uiQOE","NavigationLevel","150252422946357344"],["uiAction","renoRefresh","150693726411601076"],["uiQOE","appSession","150755662674435967"],["uiQOE","userSession","150755662622682232"],["uiAction","navigate","150755663756288523"]],"sequence":"2013"},{"category":"uiAction","modalView":"playback","kids":false,"data":{"sourceModalView":"homeScreen"},"dataContext":{},"type":"sessionEnded","name":"navigate.ended","sessionName":"navigate","time":1507556638593,"id":"15075566387693323","sessionId":"150755663756288523","duration":1502,"activeSessions":[["uiQOE","NavigationLevel","150252422946357344"],["uiAction","renoRefresh","150693726411601076"],["uiQOE","appSession","150755662674435967"],["uiQOE","userSession","150755662622682232"]],"sequence":"2014"}],"locale":"de-DE","device":{"utcOffset":-7200000},"version":{"app":"shakti-f491d84f","ui":"akira"},"browser":{"userAgent":"Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_6) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/61.0.3163.100 Safari/537.36","requestUrl":"https://www.netflix.com/watch/70178007?trackId=15035895&tctx=2%2C0%2C5a16eaa6-82d2-462f-9a62-90c56cb609ef-49931493","referrerUrl":""},"appName":"www","time":1507556642092,"retryCount":0}

I wasn't yet able to succesfully create an request with the same characteristics from within the plugin, as it seems that this is highly related to the current episode/movie your watching and a bunch of other UI reporting stuff (that we don't have in the plugin). Wasn't able to generate a working stripped down solution.
Also, afaik, Kodi does not offer a periodic way to communicate the player status from within the main thread. It could be done using some hacks, a timer & the already available service, but I´ve not looked deeper into this, as I first wanted to get the request payload straight (tested using sending modified requests from within curl on the terminal).
I´m happy for everyone who wants to look into this.

Hi,
Will https://trakt.tv/ help in this issue?

@ymca11 Unfortuanately not. We need to solve this on an Netflix API level :(

Hi. Is this connected to "watched"status of episodes in Kodi addon? Because now, there's no sign which episodes are already watched.

The current version is already tracking playback progress at a per second interval. For items that were exported to the Kodi library, this status is saved to the DB. Unfortunately there's still no way to report this back to Netflix.


Plugin is broken with gradle 4.5

The error is:
Could not find matching constructor for: org.gradle.process.internal.JavaExecHandleBuilder(org.gradle.api.internal.file.BaseDirFileResolver)

I migrated the plugin for Gradle 4.5 (see new branch).

Thanks for migrating the plugin, I've just stumbled about this problem today!
But as I'm new to gradle I can't figure out how use a locally compiled plugin version and the new version does not seem to be released in the official repositories. Can you give me a hint?

I have this same issue but would like to not have to use a local copy of the plugin.  My problem si with gradle 4.9 but it's the same.  Any chance of getting this released?

I do have the same problem with version 1.1.1 and gradle 4.10.2


Development: Use Athene Client Dependency from Maven Central

Description
So far, we used the Athene client as a .jar file stored in the lib directory. This is not a best practice and I eventually published the client to Maven central. This PR switches from the JAR file to a proper dependency.
Steps for Testing

Create a text exercise with Automatic assessment enabled
Create at least 10 identical submissions with English text and multiple sentences (e.g., copy from Wikipedia)
Exercise Deadline
check cluster statistics after ~ 2min and find clusters.
Assess submissions
Find feedback suggestions starting with second assessment.

Review Progress

Code Review

[ ] Review 1
[ ] Review 2

Manual Tests

[ ] Test 1
[ ] Test 2

⚠ Note: Currently syncing to Maven Central. Might take some time until the dependency is resolvable.


Fixed typo in assert in Texture::update

I decided to create a pull request so that this issue does not get forgotten.

Absolutely :+1:

SFMLBuildMaster: Build this please.


WARN	Keyword 'Capture Page Screenshot' could not be run on failure: NoSuchWindowException: Message: u'Unable to get browser'

While executing the test cases on IE 9,10 and 11. I am getting  a warning
messagwe "Keyword 'Capture Page Screenshot' could not be run on failure:
NoSuchWindowException: Message: u'Unable to get browser' "

However, it's working well on chrome.

I am using

Selenium2Library,RobotFramework 2.8.3
Python 2.7.5 64-bit and Windows 7 64-bit

Can you please assist me in resolving this issue?

Cheers.
Zac

Original issue reported on code.google.com by<EMAIL_ADDRESS>on 25 Jan 2014 at 6:38

Could anyone help me on the same issue.Please i need help on this very urgently..


Update sbt-sonatype to 3.9.4

Updates org.xerial.sbt:sbt-sonatype from 3.9.3 to 3.9.4.
GitHub Release Notes - Release Notes - Version Diff
I'll automatically update this PR to resolve conflicts as long as you don't change it yourself.
If you'd like to skip this version, you can just close this PR. If you have any feedback, just mention me in the comments below.
Configure Scala Steward for your repository with a .scala-steward.conf file.
Have a fantastic day writing Scala!

Ignore future updates
Add this to your .scala-steward.conf file to ignore future updates of this dependency:
updates.ignore = [ { groupId = "org.xerial.sbt", artifactId = "sbt-sonatype" } ]

labels: sbt-plugin-update, semver-patch

Codecov Report

Merging #589 into master will increase coverage by 0.07%.
The diff coverage is n/a.

@@            Coverage Diff             @@
##           master     #589      +/-   ##
==========================================
+ Coverage   78.04%   78.12%   +0.07%
==========================================
  Files         120      120
  Lines        3913     3913
  Branches       90       90
==========================================
+ Hits         3054     3057       +3
+ Misses        859      856       -3

Impacted Files
Coverage Δ

...e/akka/actor/process_index/ProcessIndexProto.scala
99.50% <0.00%> (+1.48%)
:arrow_up:

Continue to review full report at Codecov.

Legend - Click here to learn more
Δ = absolute <relative> (impact), ø = not affected, ? = missing data
Powered by Codecov. Last update 9780d79...5cce288. Read the comment docs.


feat: use webpack caching in development

This cuts build time for build-workers considerably.
I also removed the echos.  In part because they made it hard to pass args around and in part because I don't think they're very useful.
Finally, I took out build:workers:debug because I've never used it.

Feel free to add a commit here, and merge.

Just for radar: Gatsby makes a potentially useful point here:
Hi from the Gatsby maintainers! Based on what we see in your site, these coming
features may help you. All of these can be enabled within gatsby-config.js via
flags (samples below)

Preserve webpack's Cache (https://github.com/gatsbyjs/gatsby/discussions/28331), which
changes Gatsby's cache clearing behavior to not clear webpack's
cache unless you run "gatsby clean" or delete the .cache folder manually.
Here's how to try it:

module.exports = {
  flags: { PRESERVE_WEBPACK_CACHE: true },
  plugins: [...]
}

Obviously, not before it is ready, but if we are storing the webpack cache on the filesystem for persistence, then we may not want Gatsby to clear it.

@ShaunSHamilton I think we're okay: I tried gatsby clean and it didn't touch this webpack cache. AFAIK, all the Gatsby cache files, including webpack, are held separately in client/.cache


PR Luis Garcia Garces

The new feature allow users to access to /rings-quote and visualize a quote from one of the films of the Lord of the Rings.

I think it's done. Please, check it out.

I added a Kubernetes deployment on local for the application


When using azd down with a template with a VNET/NSG, it sometimes fails because NSG can't be deleted first.

[X] Make sure you've installed the latest version using instructions in the wiki

Output from azd version
Run azd version and copy and paste the output here:
azd version 1.0.2 (commit 145e046b1ea9394bd4e1b1d539eb32e860d692fb)
Describe the bug
I have a template that creates a VNET and a set of NSGs, using bicep as the infra language.  When using "azd down", the order of operations is important.  You cannot delete the NSGs prior to the VNET because you get an error
ERROR: deleting infrastructure: error deleting Azure resources: deleting resource groups: deleting resource group: GET https://management.azure.com/subscriptions/XXX/operationresults/eyJqb2JJZCI6IlJFU09VUkNFR1JPVVBERUxFVElPTkpPQi1SRzoyREFIOjJEMDcxMDoyREhVQjoyRERFVjoyREFVU1RSQUxJQUVBU1Q6MkRTUE9LRS1BVVNUUkFMSUFFQVNUIiwiam9iTG9jYXRpb24iOiJhdXN0cmFsaWFlYXN0In0
--------------------------------------------------------------------------------
RESPONSE 409: 409 Conflict
ERROR CODE: ResourceGroupDeletionBlocked
--------------------------------------------------------------------------------

To Reproduce
Clone https://github.com/adrianhall/field-engineer
Run the following:
azd env new
azd env set NETWORK_ISOLATION true
azd env set DEPLOY_HUB_NETWORK true
azd provision

Once deployed, run azd down - the error is intermittent since it's due to an ordering issue.
Expected behavior
I expect azd down to delete the VNET first and the NSGs second.

To follow-on, there is actually an ordering when using split resource groups.
I believe the issue is that my App Service (in later resource group) is VNET integrated, which causes the VNET to not be able to be deleted, which causes the NSG to not be deleted.

To follow-on, there is actually an ordering when using split resource groups.

Very likely - the way azd down works today is that it discovers all the resource groups from the most recent deployment and then deletes each one individually (and I don't even think the order in which these deletes are scheduled is stable, which is quite unfortunate!).

I believe the issue is that my App Service (in later resource group) is VNET integrated, which causes the VNET to not be able to be deleted, which causes the NSG to not be deleted

I'm wondering if it would be possible for us to discover these cross resource group dependencies and schedule our deletions in such a way that we wouldn't run into this, assuming there are no cycles (which it seems like there could be in the limit).
Or perhaps there's some way to encode a dependency delete order in the template, or something similar.
@adrianhall - Looking briefly at your template it looks like there is some general teardown order that you as the template author could propose.  I'm guessing that when it comes to deleting these resource groups, you would want to tear down the spoke resource group before the hub resource group and ensure both of them are gone before you delete the main resource group (the one that is not conditional?)

Yeah - I am producing a "cleanup.ps1", which encodes everything. The things that need special treatment:

diagnostic settings for all resources
budgets associated with a resource group
private endpoints
app services (and other services that are vnet integrated or injected)
peerings between virtual networks
things that need to be purged (api management, key vault, unless included in #4)

At this point, I believe the resource groups can all be deleted in parallel.


python311Packages.sseclient-py: 1.7.2 -> 1.8.0

Diff: https://github.com/mpetazzoni/sseclient/compare/sseclient-py-1.7.2...sseclient-py-1.8.0
Description of changes

Things done

Built on platform(s)

[ ] x86_64-linux
[ ] aarch64-linux
[ ] x86_64-darwin
[ ] aarch64-darwin

[ ] For non-Linux: Is sandbox = true set in nix.conf? (See Nix manual)
[ ] Tested, as applicable:

NixOS test(s) (look inside nixos/tests)
and/or package tests
or, for functions and "core" functionality, tests in lib/tests or pkgs/test
made sure NixOS tests are linked to the relevant packages

[ ] Tested compilation of all packages that depend on this change using nix-shell -p nixpkgs-review --run "nixpkgs-review rev HEAD". Note: all changes have to be committed, also see nixpkgs-review usage
[ ] Tested basic functionality of all binary files (usually in ./result/bin/)
23.11 Release Notes (or backporting 23.05 Release notes)

[ ] (Package updates) Added a release notes entry if the change is major or breaking
[ ] (Module updates) Added a release notes entry if the change is significant
[ ] (Module addition) Added a release notes entry if adding a new NixOS module

[ ] Fits CONTRIBUTING.md.

Result of nixpkgs-review pr 254344 run on x86_64-linux 1

16 packages built:

blocksat-cli (python310Packages.blocksat-cli)
blocksat-cli.dist (python310Packages.blocksat-cli.dist)
python310Packages.pyarlo
python310Packages.pyarlo.dist
python310Packages.python-nest
python310Packages.python-nest.dist
python310Packages.sseclient-py
python310Packages.sseclient-py.dist
python311Packages.blocksat-cli
python311Packages.blocksat-cli.dist
python311Packages.pyarlo
python311Packages.pyarlo.dist
python311Packages.python-nest
python311Packages.python-nest.dist
python311Packages.sseclient-py
python311Packages.sseclient-py.dist


Can not connect consumer to aws MSK

Description
I have managed AWS MSK instance.
Confluent.Kafka version : 1.9.0
OS: WIN.
Consumer code :
public class Consumer
    {
        private readonly ConsumerConfig _consumerConfig;

        public Consumer(string bootstrapServer)
        {
            _consumerConfig = new ConsumerConfig
            {
                BootstrapServers = bootstrapServer,
                EnableAutoCommit = false,
                EnableAutoOffsetStore = false,
                MaxPollIntervalMs = 300000,
                GroupId = "default",
                //Debug = "consumer,topic",
                //MetadataMaxAgeMs = 60000,
                MaxPartitionFetchBytes = 1,
                SaslPassword = "***",
                SaslUsername = "***",
                SaslMechanism = SaslMechanism.ScramSha512,
                SecurityProtocol = SecurityProtocol.SaslSsl,
                Debug = "broker",
                // Debug = "broker,security,protocol,feature",

                // Debug = "broker,msg,consumer,cgrp,security,protocol,topic,fetch",
                // Read messages from start if no commit exists.
                AutoOffsetReset = AutoOffsetReset.Earliest
            };
        }

        public void StartReceivingMessages(string topicName)
        {
            // check connectivity
            var adminConfig = new AdminClientConfig(_consumerConfig);
            using var admin = new AdminClientBuilder(adminConfig).SetErrorHandler((x, e) =>
            {
                Console.WriteLine(e);
            }).Build();
            var metadata = admin.GetMetadata(TimeSpan.FromSeconds(5));
            bool exist = metadata.Topics.Any(x => x.Topic == topicName);
            Console.WriteLine($"Topic {topicName} exist");
            // end connectivity check
            using var consumer = new ConsumerBuilder<string, string>(_consumerConfig)
                .SetKeyDeserializer(Deserializers.Utf8)
                .SetValueDeserializer(Deserializers.Utf8)
                .SetErrorHandler((_, e) =>
                {
                    Console.WriteLine($"Error handler: {e.Reason}");

                })
                .SetLogHandler((_, l) => Console.WriteLine(l.Message))

                 .SetStatisticsHandler((_, json) => Console.WriteLine($"Statistics: {json}"))
                .SetPartitionsAssignedHandler((c, partitions) =>
                {
                    // Since a cooperative assignor (CooperativeSticky) has been configured, the
                    // partition assignment is incremental (adds partitions to any existing assignment).
                    Console.WriteLine(
                        "Partitions  assigned: [" +
                        string.Join(',', partitions.Select(p => p.Partition.Value)) +
                        "], all: [" +
                        string.Join(',', c.Assignment.Concat(partitions).Select(p => p.Partition.Value)) +
                        "]");

                    // Possibly manually specify start offsets by returning a list of topic/partition/offsets
                    // to assign to, e.g.:
                    // return partitions.Select(tp => new TopicPartitionOffset(tp, externalOffsets[tp]));
                })
                .SetPartitionsRevokedHandler((c, partitions) =>
                {
                    // Since a cooperative assignor (CooperativeSticky) has been configured, the revoked
                    // assignment is incremental (may remove only some partitions of the current assignment).
                    var remaining = c.Assignment.Where(atp => partitions.Where(rtp => rtp.TopicPartition == atp).Count() == 0);
                    Console.WriteLine(
                        "Partitions incrementally revoked: [" +
                        string.Join(',', partitions.Select(p => p.Partition.Value)) +
                        "], remaining: [" +
                        string.Join(',', remaining.Select(p => p.Partition.Value)) +
                        "]");
                })
                .SetPartitionsLostHandler((c, partitions) =>
                {
                    // The lost partitions handler is called when the consumer detects that it has lost ownership
                    // of its assignment (fallen out of the group).
                    Console.WriteLine($"Partitions were lost: [{string.Join(", ", partitions)}]");
                })
                .Build();
            try
            {
                consumer.Subscribe(topicName);

                Console.WriteLine("\nConsumer loop started...\n\n");
                while (true)
                {
                    var timeoutMs = _consumerConfig.MaxPollIntervalMs - 1000 ?? 250000;
                    timeoutMs = 1000;
                    var result =
                        consumer.Consume(
                            TimeSpan.FromMilliseconds(timeoutMs));
                    var message = result?.Message?.Value;
                    if (message == null)
                    {
                        continue;
                    }

                    Console.WriteLine(
                        $"Received: {result.Message.Key}:{message} from partition: {result.Partition.Value}");

                    consumer.Commit(result);
                    consumer.StoreOffset(result);
                    // Thread.Sleep(TimeSpan.FromSeconds(1));
                }
            }
            catch (KafkaException e)
            {
                Console.WriteLine($"Consume error: {e.Message}");
                Console.WriteLine("Exiting producer...");
            }
            finally
            {
                consumer.Close();
            }
        }
    }

Before starting the consumer the loop i am checking the connectivity using IAdminClient.
This works fine.
Then I'm trying to consume the topic.
Consumer ErrorHandler callback fired with :
sasl_ssl://b-2.***.kafka.us-east-1.amazonaws.com:9096/2: Connect to ipv4#*** failed: Unknown error (after 21036ms in state CONNECT).
What is the problem with consumer setup?
Im sure that the connection and security config is OK, since I'm able to get metadata and to create a topic using the admin client with the same config.
Log:
%7|1656341424.450|BROKER|rdkafka#producer-1| [thrd:app]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Added new broker with NodeId -1
%7|1656341424.450|BRKMAIN|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Enter main broker thread
%7|1656341424.450|BRKMAIN|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Enter main broker thread
%7|1656341424.450|BROKER|rdkafka#producer-1| [thrd:app]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/bootstrap: Added new broker with NodeId -1
%7|1656341424.450|BROKER|rdkafka#producer-1| [thrd:app]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Added new broker with NodeId -1
%7|1656341424.450|BRKMAIN|rdkafka#producer-1| [thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/bootstrap: Enter main broker thread
%7|1656341424.450|CONNECT|rdkafka#producer-1| [thrd:app]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s))
%7|1656341424.450|BRKMAIN|rdkafka#producer-1| [thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Enter main broker thread
%7|1656341424.450|INIT|rdkafka#producer-1| [thrd:app]: librdkafka v1.9.0 (0x10900ff) rdkafka#producer-1 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer,http,oidc, SSL ZLIB SNAPPY ZSTD CURL SASL_SCRAM SASL_OAUTHBEARER PLUGINS HDRHISTOGRAM, debug 0x2)
%7|1656341424.450|CONNECT|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Received CONNECT op
%7|1656341424.450|STATE|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state INIT -> TRY_CONNECT
%4|1656341424.450|CONFWARN|rdkafka#producer-1| [thrd:app]: Configuration property group.id is a consumer property and will be ignored by this producer instance
%4|1656341424.450|CONFWARN|rdkafka#producer-1| [thrd:app]: Configuration property max.poll.interval.ms is a consumer property and will be ignored by this producer instance
%4|1656341424.450|CONFWARN|rdkafka#producer-1| [thrd:app]: Configuration property enable.auto.commit is a consumer property and will be ignored by this producer instance
%4|1656341424.451|CONFWARN|rdkafka#producer-1| [thrd:app]: Configuration property enable.auto.offset.store is a consumer property and will be ignored by this producer instance
%4|1656341424.451|CONFWARN|rdkafka#producer-1| [thrd:app]: Configuration property fetch.message.max.bytes is a consumer property and will be ignored by this producer instance
%7|1656341424.450|CONNECT|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: broker in state TRY_CONNECT connecting
%7|1656341424.451|STATE|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
%4|1656341424.451|CONFWARN|rdkafka#producer-1| [thrd:app]: Configuration property auto.offset.reset is a consumer property and will be ignored by this producer instance
%7|1656341424.475|CONNECT|rdkafka#producer-1| [thrd:app]: Not selecting any broker for cluster connection: still suppressed for 25ms: application metadata request
%7|1656341424.476|CONNECT|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Connecting to ipv4#<IP_ADDRESS>:9096 (sasl_ssl) with socket 1156
%7|1656341424.615|CONNECT|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Connected to ipv4#<IP_ADDRESS>:9096
%7|1656341424.615|STATE|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state CONNECT -> SSL_HANDSHAKE
%7|1656341424.615|CONNECT|rdkafka#producer-1| [thrd:app]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Selected for cluster connection: application metadata request (broker has 0 connection attempt(s))
%7|1656341424.616|CONNECT|rdkafka#producer-1| [thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Received CONNECT op
%7|1656341424.616|STATE|rdkafka#producer-1| [thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state INIT -> TRY_CONNECT
%7|1656341424.616|CONNECT|rdkafka#producer-1| [thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: broker in state TRY_CONNECT connecting
%7|1656341424.616|STATE|rdkafka#producer-1| [thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
%7|1656341424.616|CONNECT|rdkafka#producer-1| [thrd:app]: Not selecting any broker for cluster connection: still suppressed for 49ms: application metadata request
%7|1656341424.616|CONNECT|rdkafka#producer-1| [thrd:app]: Not selecting any broker for cluster connection: still suppressed for 49ms: application metadata request
%7|1656341424.632|CONNECT|rdkafka#producer-1| [thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Connecting to ipv4#<IP_ADDRESS>:9096 (sasl_ssl) with socket 1192
%7|1656341424.869|CONNECT|rdkafka#producer-1| [thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Connected to ipv4#<IP_ADDRESS>:9096
%7|1656341424.869|STATE|rdkafka#producer-1| [thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state CONNECT -> SSL_HANDSHAKE
%7|1656341424.869|CONNECT|rdkafka#producer-1| [thrd:app]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/bootstrap: Selected for cluster connection: application metadata request (broker has 0 connection attempt(s))
%7|1656341424.869|CONNECT|rdkafka#producer-1| [thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/bootstrap: Received CONNECT op
%7|1656341424.870|STATE|rdkafka#producer-1| [thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state INIT -> TRY_CONNECT
%7|1656341424.870|CONNECT|rdkafka#producer-1| [thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/bootstrap: broker in state TRY_CONNECT connecting
%7|1656341424.870|STATE|rdkafka#producer-1| [thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
%7|1656341424.870|CONNECT|rdkafka#producer-1| [thrd:app]: Not selecting any broker for cluster connection: still suppressed for 49ms: application metadata request
%7|1656341424.870|CONNECT|rdkafka#producer-1| [thrd:app]: Not selecting any broker for cluster connection: still suppressed for 49ms: application metadata request
%7|1656341424.900|CONNECT|rdkafka#producer-1| [thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/bootstrap: Connecting to ipv4#********:9096 (sasl_ssl) with socket 1216
%7|1656341425.010|CONNECTED|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Connected (#1)
%7|1656341425.010|FEATURE|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1656341425.010|STATE|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state SSL_HANDSHAKE -> APIVERSION_QUERY
%7|1656341425.010|CONNECT|rdkafka#producer-1| [thrd:app]: Cluster connection already in progress: application metadata request
%7|1656341425.149|FEATURE|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq
%7|1656341425.149|AUTH|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Auth in state APIVERSION_QUERY (handshake supported)
%7|1656341425.149|STATE|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state APIVERSION_QUERY -> AUTH_HANDSHAKE
%7|1656341425.149|CONNECT|rdkafka#producer-1| [thrd:app]: Cluster connection already in progress: application metadata request
%7|1656341425.270|CONNECTED|rdkafka#producer-1| [thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Connected (#1)
%7|1656341425.270|FEATURE|rdkafka#producer-1| [thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1656341425.270|STATE|rdkafka#producer-1| [thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state SSL_HANDSHAKE -> APIVERSION_QUERY
%7|1656341425.270|CONNECT|rdkafka#producer-1| [thrd:app]: Cluster connection already in progress: application metadata request
%7|1656341425.288|SASLMECHS|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker supported SASL mechanisms: SCRAM-SHA-512
%7|1656341425.289|AUTH|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Auth in state AUTH_HANDSHAKE (handshake supported)
%7|1656341425.289|STATE|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state AUTH_HANDSHAKE -> AUTH_REQ
%7|1656341425.289|CONNECT|rdkafka#producer-1| [thrd:app]: Not selecting any broker for cluster connection: still suppressed for 31ms: application metadata request
%7|1656341425.409|FEATURE|rdkafka#producer-1| [thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq
%7|1656341425.409|AUTH|rdkafka#producer-1| [thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Auth in state APIVERSION_QUERY (handshake supported)
%7|1656341425.409|STATE|rdkafka#producer-1| [thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state APIVERSION_QUERY -> AUTH_HANDSHAKE
%7|1656341425.409|CONNECT|rdkafka#producer-1| [thrd:app]: Cluster connection already in progress: application metadata request
%7|1656341425.456|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 3ms: no cluster connection
%7|1656341425.550|SASLMECHS|rdkafka#producer-1| [thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker supported SASL mechanisms: SCRAM-SHA-512
%7|1656341425.550|AUTH|rdkafka#producer-1| [thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Auth in state AUTH_HANDSHAKE (handshake supported)
%7|1656341425.550|STATE|rdkafka#producer-1| [thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state AUTH_HANDSHAKE -> AUTH_REQ
%7|1656341425.550|CONNECT|rdkafka#producer-1| [thrd:app]: Cluster connection already in progress: application metadata request
%7|1656341425.580|SCRAMAUTH|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: SASL SCRAM authentication successful on server: verifying ServerSignature
%7|1656341425.580|SCRAMAUTH|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Authenticated as kafka using SCRAM-SHA-512
%7|1656341425.580|STATE|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state AUTH_REQ -> UP
%7|1656341425.719|UPDATE|rdkafka#producer-1| [thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/bootstrap: NodeId changed from -1 to 2
%7|1656341425.719|UPDATE|rdkafka#producer-1| [thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Name changed from sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/bootstrap to sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2
%7|1656341425.719|LEADER|rdkafka#producer-1| [thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Mapped 0 partition(s) to broker
%7|1656341425.720|UPDATE|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: NodeId changed from -1 to 3
%7|1656341425.720|UPDATE|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3: Name changed from sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap to sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3
%7|1656341425.720|LEADER|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3: Mapped 0 partition(s) to broker
%7|1656341425.720|STATE|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3: Broker changed state UP -> UPDATE
%7|1656341425.720|STATE|rdkafka#producer-1| [thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3: Broker changed state UPDATE -> UP
%7|1656341425.720|UPDATE|rdkafka#producer-1| [thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: NodeId changed from -1 to 1
%7|1656341425.720|UPDATE|rdkafka#producer-1| [thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/1: Name changed from sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap to sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/1
%7|1656341425.720|LEADER|rdkafka#producer-1| [thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/1: Mapped 0 partition(s) to broker
%7|1656341425.720|CLUSTERID|rdkafka#producer-1| [thrd:main]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3: ClusterId update "" -> "t8AWTsBiSRuwg1RNaSB5Ng"
%7|1656341425.721|CONTROLLERID|rdkafka#producer-1| [thrd:main]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3: ControllerId update -1 -> 1
%7|1656341425.843|SCRAMAUTH|rdkafka#producer-1| [thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/1: SASL SCRAM authentication successful on server: verifying ServerSignature
%7|1656341425.843|SCRAMAUTH|rdkafka#producer-1| [thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/1: Authenticated as kafka using SCRAM-SHA-512%7|1656341425.843|STATE|rdkafka#producer-1| [thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/1: Broker changed state AUTH_REQ -> UP
Topic test-topic exist
[thrd:app]: GroupCoordinator: Added new broker with NodeId -1
[thrd:GroupCoordinator]: GroupCoordinator: Enter main broker thread
[thrd:app]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Added new broker with NodeId -1
[thrd::0/internal]: :0/internal: Enter main broker thread
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Enter main broker thread
[thrd:app]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/bootstrap: Added new broker with NodeId -1
[thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/bootstrap: Enter main broker thread
[thrd:app]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Added new broker with NodeId -1
[thrd:app]: librdkafka v1.9.0 (0x10900ff) rdkafka#consumer-2 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer,http,oidc, SSL ZLIB SNAPPY ZSTD CURL SASL_SCRAM SASL_OAUTHBEARER PLUGINS HDRHISTOGRAM, debug 0x2)
[thrd:main]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Selected for cluster connection: coordinator query (broker has 0 connection attempt(s))
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Enter main broker thread
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Received CONNECT op
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state INIT -> TRY_CONNECT
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: broker in state TRY_CONNECT connecting
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Connecting to ipv4#<IP_ADDRESS>:9096 (sasl_ssl) with socket 1448
[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 48ms: coordinator query

Consumer loop started...

[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Connected to ipv4#<IP_ADDRESS>:9096
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state CONNECT -> SSL_HANDSHAKE
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Connected (#1)
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state SSL_HANDSHAKE -> APIVERSION_QUERY
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Auth in state APIVERSION_QUERY (handshake supported)
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state APIVERSION_QUERY -> AUTH_HANDSHAKE
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker supported SASL mechanisms: SCRAM-SHA-512
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Auth in state AUTH_HANDSHAKE (handshake supported)
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state AUTH_HANDSHAKE -> AUTH_REQ
[thrd:main]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Selected for cluster connection: coordinator query (broker has 0 connection attempt(s))
[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Received CONNECT op
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state INIT -> TRY_CONNECT
[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: coordinator query
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: broker in state TRY_CONNECT connecting
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Connecting to ipv4#<IP_ADDRESS>:9096 (sasl_ssl) with socket 1488
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: SASL SCRAM authentication successful on server: verifying ServerSignature
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Authenticated as kafka using SCRAM-SHA-512
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state AUTH_REQ -> UP
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Connected to ipv4#<IP_ADDRESS>:9096
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: Broker changed state CONNECT -> SSL_HANDSHAKE
[thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/bootstrap: NodeId changed from -1 to 2
[thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Name changed from sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/bootstrap to sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2
[thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Mapped 0 partition(s) to broker
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: NodeId changed from -1 to 3
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3: Name changed from sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap to sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3: Mapped 0 partition(s) to broker
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap: NodeId changed from -1 to 1
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/1: Name changed from sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/bootstrap to sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/1
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/1: Mapped 0 partition(s) to broker
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/1: Broker changed state UP -> UPDATE
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/1: Broker changed state UPDATE -> UP
[thrd:main]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/1: ClusterId update "" -> "t8AWTsBiSRuwg1RNaSB5Ng"
[thrd:main]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/1: ControllerId update -1 -> 1
[thrd:main]: GroupCoordinator: Broker nodename changed from "" to "b-1.********.c22.kafka.us-east-1.amazonaws.com:9096"
[thrd:main]: GroupCoordinator: Broker nodeid changed from -1 to 1
[thrd:GroupCoordinator]: GroupCoordinator: Received CONNECT op
[thrd:GroupCoordinator]: GroupCoordinator: Broker changed state INIT -> TRY_CONNECT
[thrd:GroupCoordinator]: GroupCoordinator/1: broker in state TRY_CONNECT connecting
[thrd:GroupCoordinator]: GroupCoordinator: Broker changed state TRY_CONNECT -> CONNECT
[thrd:GroupCoordinator]: GroupCoordinator/1: Connecting to ipv4#<IP_ADDRESS>:9096 (sasl_ssl) with socket 1512
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3: Connected (#1)
[thrd:GroupCoordinator]: GroupCoordinator/1: Connected to ipv4#<IP_ADDRESS>:9096
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3: Updated enabled protocol features +ApiVersion to ApiVersion
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3: Broker changed state SSL_HANDSHAKE -> APIVERSION_QUERY
[thrd:GroupCoordinator]: GroupCoordinator: Broker changed state CONNECT -> SSL_HANDSHAKE
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3: Auth in state APIVERSION_QUERY (handshake supported)
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3: Broker changed state APIVERSION_QUERY -> AUTH_HANDSHAKE
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3: Broker supported SASL mechanisms: SCRAM-SHA-512
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3: Auth in state AUTH_HANDSHAKE (handshake supported)
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3: Broker changed state AUTH_HANDSHAKE -> AUTH_REQ
[thrd:GroupCoordinator]: GroupCoordinator/1: Connected (#1)
[thrd:GroupCoordinator]: GroupCoordinator/1: Updated enabled protocol features +ApiVersion to ApiVersion
[thrd:GroupCoordinator]: GroupCoordinator: Broker changed state SSL_HANDSHAKE -> APIVERSION_QUERY
[thrd:GroupCoordinator]: GroupCoordinator/1: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq
[thrd:GroupCoordinator]: GroupCoordinator/1: Auth in state APIVERSION_QUERY (handshake supported)
[thrd:GroupCoordinator]: GroupCoordinator: Broker changed state APIVERSION_QUERY -> AUTH_HANDSHAKE
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3: SASL SCRAM authentication successful on server: verifying ServerSignature
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3: Authenticated as kafka using SCRAM-SHA-512
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3: Broker changed state AUTH_REQ -> UP
[thrd:GroupCoordinator]: GroupCoordinator/1: Broker supported SASL mechanisms: SCRAM-SHA-512
[thrd:GroupCoordinator]: GroupCoordinator/1: Auth in state AUTH_HANDSHAKE (handshake supported)
[thrd:GroupCoordinator]: GroupCoordinator: Broker changed state AUTH_HANDSHAKE -> AUTH_REQ
[thrd:GroupCoordinator]: GroupCoordinator/1: SASL SCRAM authentication successful on server: verifying ServerSignature
[thrd:GroupCoordinator]: GroupCoordinator/1: Authenticated as kafka using SCRAM-SHA-512
[thrd:GroupCoordinator]: GroupCoordinator: Broker changed state AUTH_REQ -> UP
[thrd:main]: GroupCoordinator/1: JoinGroupRequest failed: Broker: Group member needs a valid member ID: explicit actions Ignore
Partitions  assigned: [3,4], all: [3,4]
[thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Topic test-topic [0]: joining broker (rktp 000001FFE8A38F90, 0 message(s) queued)
[thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Topic test-topic [3]: joining broker (rktp 000001FFE8A3C4B0, 0 message(s) queued)
[thrd:sasl_ssl://b-1.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-1.********.c22.kafka.us-east-1.amazonaws.com:9096/1: Topic test-topic [2]: joining broker (rktp 000001FFE8A39870, 0 message(s) queued)
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3: Topic test-topic [1]: joining broker (rktp 000001FFE8A39400, 0 message(s) queued)
[thrd:sasl_ssl://b-3.********.c22.kafka.us-east-1.amazona]: sasl_ssl://b-3.********.c22.kafka.us-east-1.amazonaws.com:9096/3: Topic test-topic [4]: joining broker (rktp 000001FFE8A3C920, 0 message(s) queued)
[thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Broker changed state INIT -> TRY_CONNECT
[thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: broker in state TRY_CONNECT connecting
[thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Broker changed state TRY_CONNECT -> CONNECT
[thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Connecting to ipv4#********:9096 (sasl_ssl) with socket 1536
%7|1656341445.951|FAIL|rdkafka#producer-1| [thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Connect to ipv4#********:9096 failed: Unknown error (after 21079ms in state CONNECT) (_TRANSPORT)
%3|1656341445.951|FAIL|rdkafka#producer-1| [thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Connect to ipv4#********:9096 failed: Unknown error (after 21079ms in state CONNECT)
%7|1656341445.951|STATE|rdkafka#producer-1| [thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Broker changed state CONNECT -> DOWN
%7|1656341445.951|STATE|rdkafka#producer-1| [thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Broker changed state DOWN -> INIT
sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Connect to ipv4#********:9096 failed: Unknown error (after 21079ms in state CONNECT)
[thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Connect to ipv4#********:9096 failed: Unknown error (after 21036ms in state CONNECT) (_TRANSPORT)
[thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Connect to ipv4#********:9096 failed: Unknown error (after 21036ms in state CONNECT)
[thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Broker changed state CONNECT -> DOWN
[thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Broker changed state DOWN -> INIT
[thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Broker changed state INIT -> TRY_CONNECT
[thrd:main]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: ListOffsetsRequest failed: Local: Broker transport failure: explicit actions Retry
[thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Delaying next reconnect by 149ms
[thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Delaying next reconnect by 148ms
[thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Moved 1 retry buffer(s) to output queue
[thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: broker in state TRY_CONNECT connecting
[thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Broker changed state TRY_CONNECT -> CONNECT
[thrd:sasl_ssl://********.kafka.us-east-1.amazona]: sasl_ssl://********.kafka.us-east-1.amazonaws.com:9096/2: Connecting to ipv4#********:9096 (sasl_ssl) with socket 1668

Hi @sfiodorov
at StartReceivingMessages method you passed consumerConfig to AdminClientbuilder which isn't correct you should pass AdminClientConfig to AdminClientBuilder
I mean this section of your codes
  var adminConfig = new AdminClientConfig(_consumerConfig);

> instead of _consumerConfig you should pass adminClientConfig

  using var admin = new AdminClientBuilder(adminConfig).SetErrorHandler((x, e) => ...

also if you're using .Net 6 the SetLogHandler still has bug in this version so please remove it for this state and run your program again.
I think if you fix these bugs the consumer will work correctly

Hi.
Thanks for helping .
Yes, it it working now


Use unified format for example file name

To be consistent, changes all the example file names to be of the same format a_b_c..._n.

Hi @Yuhta, could you help review this PR? It is a file name clean up.


Add input parameters to StreamLines.get_start_points

As mentioned in https://github.com/3b1b/manim/issues/994, attempting to initialise StreamLines with any values set in "start_points_generator_config" results in
TypeError: get_start_points() got an unexpected keyword argument 'delta_x'

A minimal example:
from manimlib.mobject.vector_field import StreamLines

stream_line_config = {
    "start_points_generator_config": {
        "delta_x": 0.1
    }
}
sl = StreamLines(lambda x: x, **stream_line_config)

The error is due to the initialise method of StreamLines attempting to call get_start_points with keyword arguments:
https://github.com/3b1b/manim/blob/ca0b7a6b06ff7787d1efab5ad3b28cfb88f67c3f/manimlib/mobject/vector_field.py#L228-L230
However get_start_points does not accept any parameters:
https://github.com/3b1b/manim/blob/ca0b7a6b06ff7787d1efab5ad3b28cfb88f67c3f/manimlib/mobject/vector_field.py#L265
It is unclear if the configuration was handled differently in the past as "start_points_generator_config" has been used in older code, but no changes are evident in the git history.
This change provides get_start_points with parameters that default to the class config properties if no values are passed.

@eulertour any thoughts?

Seems outdated, so close this.


update to gradio 3.0.2

Upgrades to Gradio 3.0.2 as the SDK for spaces and fixes change in Dataframe.

The docs for this PR live here. All of your documentation changes will be reflected on that endpoint.


Content sharing support

Share notes to other apps
Create new notes by sharing from other apps

https://developer.android.com/training/sharing/index.html

Hey @khuttun, could you tell me which apps exactly do you want share notes

Any apps that support sharing textual content. The idea is to integrate NotificationNotes with the standard Android Intent based sharing mechanism.
I'm thinking that sharing a note to other apps would share the note text, and sharing text from other apps to NotificationNotes would open the New note view with the shared text populated in the Note text field.

Ok, I'm sorry for answer you late, but I'm going to work on it!

Cool

@diegoalvis What's your status on this? let me know if i can help

Hey @sathyapriya31 I'm just to send the PR, thank you!

Solved in  #26

I don't know if this is even possible, but how awesome would it be if I could share e.g. a text or an email or anything really with this app, i.e. select this app as destination for sharing, and have that create a notification that links straight to the item I shared?

I don't know if this is even possible, but how awesome would it be if I could share e.g. a text or an email or anything really with this app, i.e. select this app as destination for sharing, and have that create a notification that links straight to the item I shared?

It's definitely possible to set NotificationNotes as a target for sharing. Don't know about the linking though.


Chain of Thought Prompting Elicits Reasoning in Large Language Models

집현전 3기 4조 Chain of Thought Prompting.pdf


how to debug the fpga?

I wonder if anyone has used iverilog to debug the FPGA?  That plus gtkwave are a very powerful pair of applications to debug.
It would require a bit of setup with some test scripts but might help debug custom FPGA changes.

Here is an example of the output from gtkwave during the startup of the iir module

I haven't! But I'm interested in this topic. What's the advantage of iverilog? Can we use vivado's simulator for this purpose?

The advantage of iverilog is that it is quick to make changes and re-run the simulation.  I have pushed my version of the harness here https://github.com/peteasa/pyrpl_testbench/tree/main/fpga.  This does not replace the vivado simulator, its just very quick to run with little overhead.


[QUESTION] Queued export ignores bindValue() function

Prerequisites

[X] Have read and understood: https://github.com/Maatwebsite/Laravel-Excel/blob/3.1/.github/SUPPORT.md
[X] Checked if your Laravel Excel version is still supported: https://docs.laravel-excel.com/3.1/getting-started/support.html#supported-versions
[X] Checked that your question isn't already asked before.
[X] Filled in the entire issue template

Versions

PHP version: 7.4.3
Laravel version: v7.1.2
Package version: 3.1.19

Description
I am trying to export data to csv. I am using bindValue() to pad each cell value with empty spaces to a defined length.
This is working as intended only when i don´t queue the process. If i implement the ShouldQueue contract the bindValue() function is ignored.
Output
non queued output via (new RicohExport)->store($fileName, null,  \Maatwebsite\Excel\Excel::CSV);
DEHerr      John                   Doe                      main street
DEFrau      Jane                   Doe                      main street

output when queued via (new RicohExport)->store($fileName, null,  \Maatwebsite\Excel\Excel::CSV)->allOnQueue('export');
DEHerrJohnDoemain street
DEFrauJaneDoemain street

So why is the queued export not padding the cell values via bindValue()?
RicohExport.php
<?php

namespace App\Exports;

use App\Helpers\StringHelper;
use App\Import;
use Illuminate\Contracts\Queue\ShouldQueue;
use Maatwebsite\Excel\Concerns\Exportable;
use Maatwebsite\Excel\Concerns\FromQuery;
use Maatwebsite\Excel\Concerns\WithCustomCsvSettings;
use Maatwebsite\Excel\Concerns\WithCustomValueBinder;
use Maatwebsite\Excel\Concerns\WithStrictNullComparison;
use Maatwebsite\Excel\DefaultValueBinder;
use PhpOffice\PhpSpreadsheet\Cell\Cell;
use PhpOffice\PhpSpreadsheet\Cell\Coordinate;

class RicohExport extends DefaultValueBinder implements
	FromQuery, WithCustomCsvSettings, WithCustomValueBinder,
	WithStrictNullComparison, ShouldQueue
{
	use Exportable;

	private $columns = array();
	private $columnWidths = array();
	private $columnNames = array();

	public function __construct()
	{
		$this->columns = config('importexport.ricoh');
		foreach ($this->columns as $key => $val) {
			array_push($this->columnWidths, $val);
			array_push($this->columnNames, $key);
		}
	}

	public function query() {
		return Import::query()->where('export', true)->select($this->columnNames);
	}

	public function getCsvSettings(): array
	{
		return [
			'delimiter' => '',
			'enclosure' =>'',
		];
	}

	/**
	 * Export with column string padding
	 * @param Cell $cell
	 * @param mixed $value
	 * @return bool
	 * @throws \PhpOffice\PhpSpreadsheet\Exception
	 */
	public function bindValue(Cell $cell, $value)
	{
		$columnIdx = Coordinate::columnIndexFromString($cell->getColumn()) - 1;
		$value = StringHelper::mb_str_pad($value, $this->columnWidths[$columnIdx]);

		return parent::bindValue($cell, $value);
	}
}

Can you provide a failing test for this?
Alternative would be to use the map method.

@patrickbrouwers Thx for the mapping suggestion, i think i will implement that.
I created a repo https://github.com/marcschneider123/laravel-excel with the queued export error.
ExportController@export creates two files in storage/app: export.dat with the correct padding and export_queued.dat without.
Haven´t figured out yet why it is not working when i use the ShouldQueue contract.

I managed to get it working WithMapping concern:
<?php
/**
* map each column and add string padding for export
 * @param mixed $import
 * @return array
 */
public function map($import): array
{
	$export = [];
	foreach ($this->columnNames as $idx => $column){
		array_push($export, StringHelper::mb_str_pad($import[$column], $this->columnWidths[$idx]));
	}
	return $export;
}

+1 same issue for me
But it seems if using fromView it completely ignores the mapping?!?
Is it possible to format the cell in the blade to the string type, because I have some cells beginning with =TEXT and it tries to calculate these cells during render.

Map doesn't get called when using to View. You can do the formatting inside the view.
PhpSpreadsheet has an option to set the format code via data-format on the cell: https://github.com/PHPOffice/PhpSpreadsheet/blob/master/src/PhpSpreadsheet/Reader/Html.php#L553

hey Patrick,
thanks for your reply. do I need something else for the data-format in the html?
the problem still exists with fields beginning with a = (equal sign).
I've already tried it with column format and custom value binder.
column format seems to be ignored and the custom value binder does his work, but I´ve got problems with zip codes beginning with a zero...

Are you using CSV? I don't think most column formats work for CSV.

no, I am using .xlsx
in .csv it´s working, with or without formatting (seems it doesn't matter)
de groeten naar Nederland :-)

Does the value binder work without queueing?

Value binder is working, with or without queue.
I can overwrite it there, but then I don't need to format it in the blade file.
would be nice to use all formatting it in the view.

Can you show me what you tried in the blade view

            {{ __('report.shipment_content') }}
            {{ __('report.customer_charge') }}

        @foreach($calculations as $calculation)

                {{ rtrim($calculation->shipment_content) }}
                {{ rtrim($calculation->customer_charge) }}

        @endforeach

$calculation->shipment_content may contain strings like:
2xMS165+2xMS265+1xMS

or
=11 x W265LT

So shipment_content goes wrong?
Does customer_charge work?

yeah, customer_charge is working (defined as number, 2 decimal places, use 1000 separator)😕

I think "text" is perhaps wrong/invalid format type?

Yes, it needs to be @. See https://github.com/PHPOffice/PhpSpreadsheet/blob/master/src/PhpSpreadsheet/Style/NumberFormat.php#L14 for the options

Hey Patrick,
thanks for the hint. Sadly it's not working with data-format='@'.
The Problem still occurs.

Can you try the StringValueBinder ?

With StringValueBinder it's working ... but it's not as elegant as I can make it complete in the blade file.
But it can be used as a workaround.
Thanks anyway for your help!
Btw, Postcard will be on its way soon 😄

I think the difference with the column format is that the string value binder explicitly sets the data type which seems to be something different than the number format (which is used in column formatting).
Thanks! Looking forward to it! :)

Same issue here - WithCustomValueBinder gets ignored when I run the export in a queue. Basically "Disable intelligent formatting" stops working which is a huge bummer to me. The solution provided by marcschneider123 did not work for me. I am missing the mb_str_pad method on the StringHelper.

If anyone can figure out why the value binder doesn't get used in the queue, feel free to PR a fix.

Thanks for PR'ing @mr-jingles , will include it in the next release

@spielfigur thanks for the postcard! We received it! :)


To explain function demod_bits()

Hi Xianjun,
Function demod_bits(a, num_bits, sample_per_symbol) implements the way how ADC samples is converted to bits.
1: Could you explain why the following code is able to determine the bit is 0 or 1:
if (I0*Q1 - I1*Q0) > 0
        bits(k) = 1;

2: If sample_per_symbol is 4, just the first two samples are used to determine the bit value of the symbol as showed in function demo_bits(). What's the purpose of the other two samples? Will they be just discarded?

I'm still confusing about it.
Anybody could explain how could it demodulate the bluetooth signal which modulated by GFSK?

The given C code represents a function called demod_byte that takes an array of IQ samples (IQ_TYPE* rxp), the number of bytes to demodulate (int num_byte), and an output array to store the demodulated bytes (uint8_t *out_byte).
Let's break down the function and understand its functionality:

Initialization:

Initialize variables i, j, I0, Q0, I1, Q1, bit_decision, and sample_idx.
i and j are loop counters used in the subsequent loops.
sample_idx keeps track of the current position in the rxp array.

Byte Demodulation Loop:

Iterate over each byte to demodulate (num_byte times).
Set the output byte to 0 before processing a new byte (out_byte[i] = 0).

Bit Demodulation Loop:

Iterate 8 times for each byte to demodulate (j<8).
Perform IQ demodulation by accessing IQ samples at specific positions in the rxp array.

I0 and Q0 store the real and imaginary parts of the current sample (rxp[sample_idx] and rxp[sample_idx+1]).
I1 and Q1 store the real and imaginary parts of the next sample (rxp[sample_idx+2] and rxp[sample_idx+3]).

Calculate the bit decision based on the demodulated IQ samples.

If (I0*Q1 - I1*Q0) is greater than 0, bit_decision is set to 1; otherwise, it is set to 0.

Store the bit decision in the appropriate position within the current byte.

The bit decision is left-shifted by j positions and combined with the existing bits using a bitwise OR operation (out_byte[i] = out_byte[i] | (bit_decision<<j)).

Update sample_idx to point to the next symbol in the rxp array by incrementing it by SAMPLE_PER_SYMBOL*2.

SAMPLE_PER_SYMBOL indicates the number of IQ samples per symbol, and the multiplication by 2 accounts for the real and imaginary parts.

Return:

The function does not have a return value, as the demodulated bytes are stored in the out_byte array, which is passed by reference.

In summary, this code performs demodulation of IQ samples to recover binary data. It processes the IQ samples in chunks of four (I0, Q0, I1, Q1) and calculates a bit decision based on the difference between the products of consecutive samples. The bit decisions are combined to form bytes, which are then stored in the output array.


codeql: Bump clang versions

also rebumps tcmalloc and adds comments about keeping clang versions in sync
Commit Message:
Additional Description:
Risk Level:
Testing:
Docs Changes:
Release Notes:
Platform Specific Features:
[Optional Runtime guard:]
[Optional Fixes #Issue]
[Optional Fixes commit #PR or SHA]
[Optional Deprecated:]
[Optional API Considerations:]

cc @keith @lizan @alyssawilk
this hasnt triggered a codeql run - ill try and run a test to trigger elsewhere

great, that seems to have worked https://github.com/envoyproxy/envoy/actions/runs/3436724618/jobs/5730585103


Intel Xeon appropriate TARGET for make

Greetings,
I'm trying to install OpenBLAS on a IBM SystemX3650 server, and having this error:
Makefile:160: *** OpenBLAS: Detecting CPU failed. Please set TARGET explicitly, e.g. make TARGET=your_cpu_target.
What would be the appropriate TARGET for make in a Intel Xeon "Netburst" (also know as "P68") arch?

Uh. Try TARGET=PRESCOTT if it is really one of the original Netburst Xeons from the early 2000s (seems IBM kept using the X3650 designation for more recent models, so I also find specifications for later cpus with AVX2 that would be SANDYBRIDGE).
What is your operating system ?

If 1st generation (and 32 bit), try TARGET=NORTHWOOD

@martin-frbg , thank you for reply. Indeed, it is a 2006 server. TARGET=PRESCOTT seems to work perfectly. Thanks!


TensorBoard Issues when trying to download CSV

Hi,
Error when I try to download a CSV of my datas : Failed - File not found
How can I retrieve this information?

Error bypassed using tensorboard.exe from kohya gui.

Hi, you can't download tensorboard csv from google colab, I suggest to download logs folder and re-run tensorboard in your local machine so you can able to download the csv.
https://github.com/tensorflow/tensorboard/issues/4243


Don't use mmap when calling pm_parse from the Ruby API

It's incredibly unlikely, but possible for the underlying bytes to be modified between the time the file is parsed and the time when we reify the Ruby AST. Since we're going to be returning the entire source to Ruby as a part of the Prism::Source object, there's not a ton of benefit to using mmap in these circumstances anyway. Let's keep it only for the C API.

I don't follow, isn't it safe to use mmap to gets all the file contents? Then one could create a Ruby String from the result of mmap, which will copy, and that RSTRING_PTR(str) could be used to parse, no?
I think fread is quite a bit slower because e.g. it does not benefit from caching.

I don't think we have any guarantee that between the time we call mmap and the time we call rb_str_new even if they're sequential that the underlying bytes haven't changed and that it's safe to memcpy. I was trying to find a way to determine if the mmap was dirty but couldn't find out.

To clarify, what I meant is one could VALUE str = rb_str_new(mmap(...)); yp_parse(RSTRING_PTR(str)).
Then it would parse on the copy, so that cannot change.
I think you're getting at whether it's safe to read from the pointer returned by mmap and how is that affected if the file is changed concurrently. Also what happens if the file is shrinked or appended to, in that case the file size from fstat() might be stale.
I would guess mmap() has protections for this and might possibly expose an older consistent snapshot of the file.
But it doesn't seem clearly specified from the man page, e.g. under MAP_PRIVATE (which Prism uses):

It is unspecified whether  changes  made to the file after the mmap() call are visible in the mapped region.

And in NOTES:

The effect of changing the size of the underlying file of a mapping on the pages that
correspond to added or removed regions of the file is unspecified.

Out of curiosity, was using mmap causing a problem in practice?

From everything I've read (including the docs that you included) mmap has no protections for this. Yes, this problem came from a user where they got a BUS error relatively consistently.


Update conf-sample.js : simple warning for sim accuracy

Added this warning to line 69 & 71. Sim seems to give non-repeatable results when using 100% balance.
(WARNING : sim won't work properly if you set this value to 100)

Good call @kuhugo !

Adding this in for now.


primtive_types should be primitive_types

Fixed by https://github.com/iskandr/serializable/commit/3c3640e144c921e799a4c0cc65d8b4fcf6aa73dc


Fix include src lambdas in zip

Hello! Is there context on this?

Hi,
Sorry i sent this PR by accident it was supposed to be to my own master branch.
Best regards,
Filip
16 juni 2020 kl. 01:01 skrev Mariam Maarouf<EMAIL_ADDRESS>
Hello! Is there context on this?
—
You are receiving this because you modified the open/close state.
Reply to this email directly, view it on GitHubhttps://github.com/mariamrf/py-lambda-action/pull/8#issuecomment-644432692, or unsubscribehttps://github.com/notifications/unsubscribe-auth/ABX2MCWR342WTZQTXZ3KRWDRW2RW7ANCNFSM4N63KYVQ.


Unnecessary call to Utilities.formatString

https://github.com/gsuitedevs/apps-script-oauth2/blob/master/src/OAuth2.js#L67
return Utilities.formatString('https://script.google.com/macros/d/%s/usercallback', scriptId);

I think that calls to Utilities.formatString should simply be replaced by:
return 'https://script.google.com/macros/d/'+scriptId+'/usercallback';

Or, if we want to be really conservative:
return 'https://script.google.com/macros/d/'+encodeURIComponent(scriptId)+'/usercallback';

I prefer the readability of formatString, but worth optimizing for performance. Done!

I like that readability too, but as the string is not configurable, I prefer the performance. Thanks!


Aesthetic changes: add (!?) and (!?>) operators + some docs.

As the title suggests:

Two new operators (!?) and (!?>) which correspond to flip lookup and flip lookupR.
Really minimal documentation for those two.
lookup note that mentions how this lookup compares to the Data.Map's lookup function.

The last one is important, I think, because it wasn't immediately obvious (for me :) )
that MonadThrow includes Maybe and lookup works the same way as Data.Map's lookup if m is Maybe.
Added this bit in the docs "for educational purposes", basically.
Again, really small change, but I think it'd make the library just this much nicer.

I'm fine with this change in principle. Some comments:

!? and !?> appear to be lookup(R), not flip lookup(R). Was this
intentional or did you miss the flip?
A quick look at hackage didn't show !? and !?> operators in
containers:Data.Map. Can you link me to their documentation so I can verify
these have similar semantics?

Thanks for the PR.
On Tue, May 10, 2022 at 2:13 PM ????????????????? @.***>
wrote:

As a side note, I originally forked this repository, because I was
surprised that it has no Semigroup/Monoid instance. After looking into it,
I'm pretty sure a non-trivial semigroup instance is basically impossible.
—
Reply to this email directly, view it on GitHub
https://github.com/joelwilliamson/bimap/pull/15#issuecomment-1122715414,
or unsubscribe
https://github.com/notifications/unsubscribe-auth/AANG27AS533PFFFH67P7DL3VJKRKZANCNFSM5VSNLCHQ
.
You are receiving this because you are subscribed to this thread.Message
ID: @.***>

Oh no. I've accidentally removed the flip change while I was fiddling with git rebase. Yeah, it's totally not intentional!
The (!?) link: https://hackage.haskell.org/package/containers-<IP_ADDRESS>/docs/Data-Map-Strict.html#v:-33--63-


Extended MQTT writer with retained interpolable field

Retained field on MQTT writer is now interpolable to allow a more granular control in complex pipelines

Great, thanks @angiglesias!


Failing to start

I was getting no response in MQTT so I started researching and ran the "Start" commend manually so I could see the results.
 sudo /usr/local/bin/aurora_mqtt_bridge /dev/ttyUSB0 mqtt://localhost/
yields
/var/lib/gems/3.0.0/gems/rmodbus-ccutrer-2.1.0/lib/rmodbus/client/slave.rb:275:in 'rescue in query': Timed out during read attempt
I have confirmed that I am referencing the correct device ttyUSB0.  I also can see on a RS-485 Module on an ESP32 that is also connected to the buss that there is data sent
61 40 0C 61 61 61 58 76 54 61 7C 62 A8 40 64 02 61 A6 40 62 FF
That packet is sent twice before it gives the timeout error.
I do have a different model USB to RS-485 Adapter than you show
You list the DSD TECH SH-U11 USB to RS485 RS422 and I have the DSD TECH SH-U10 USB to RS485 Converter. Could that be the issue or do I have something else going on?
I have a Series 7 but am unsure of the Firmware version.
Edit: I was able to send commands from the ESP32 and get that the ABC Program Version is 2.04 from register 2.

Did you ever find a solution to this?  I recently bought an adapter with a CP2012 chip.  I believe I've wired it correctly, the driver appears to be installed (loaded with /etc/modules) on RPi 3B bullseye, /dev/ttyUSB0 is present, and the device shows up on lsusb, but when I try the test you described above, I get the same "timed out" error message.  Everything works when I use the adapter that is linked to Amazon in the original writeup.


Fix crash in CaseStudies app when tapping on increment action from Alert

CaseStudies app crashes when tapping on "Increment" action from Alert.
According to my investigation, we cannot reuse var alert: AlertState<AlertAndSheetAction>? property to trigger new alert from the action of its button. This also doesn't work in vanilla SwiftUI.

@stephencelis Thanks for the reply. I will close it. FYI I'm using Xcode 11.3 and it's happening. Could you tell me which Xcode version this works in?


I fixed the Gopher SVG illustration

Hi there Go community. This might be the absolute wrong place to post about this, but I am not sure where I should put this. The SVG Gopher for Go, which is used around the web can't be resized properly. If you look around official resources of Google you can see the resized Gophers with thick borders (the border is always a certain width, even if you resize it). We are using the Gopher in our app and I fixed the SVG Gopher:
Go.svg.zip
I am not sure where to put this, but thought the community might now where.

Thank you @jeroenransijn!
/cc @campoy @bradfitz @broady, might y'all have some input on how to move forward here?

We can't take contributions on the bug tracker.
To send a change, see https://golang.org/doc/contribute.html
But actually, this svg isn't in the Go repo, so I don't think this is the right place. I guess you could announce it on the golang-nuts@ mailing list?


Use in-process pipe for user-space Wireguard (Bind interface)

Currently, we communicate with a user-space Wireguard daemon via a standard socket through kernel-space.
This can be optimized by implementing the conn.Bind interface of the wireguard package.
Some initial work started in branch wg-conn-bind.

Done, and now in master branch 🥳


_initializedAt bool instead of uint40

Hi, can't _initializedAt at https://github.com/Steemhunt/dixel-v2-contract/blob/d11a586f289b479e8d0afc72e89deb3991a92aee/contracts/DixelClubV2NFT.sol#L46 be a bool instead?
I saw it's used very little, and I don't get clearly its function. Can you clarify it?

It's being used to sort collections on the main list of the web front-end


Bookstore: add reducers and actions

👇 👇 The following file and feature were added to the branch 👇 👇
✏ Redux package were installed.
✏ New directory named redux was created.
✏ Application Redux store was configured.
✏ Under the redux directory two slice files named bookSice and Category were created.
✏ Under bookSlice addBook and removeBook reducers were added.
✏ Under Catagory status reducer that returns Under construction was added.
✏ For all slice files the initial state was assigned as an empty array.
✏ On index.js the app store and provider were imported.

Thank you so much 🙏🙏


pdo_sqlsrv segfault on strings with some characters

I have come across some data in our database (generated by casting a timestamp to a varchar) which is able to reliable segfault the pdo_sqlsrv driver (but the sqlsrv driver is able to handle it).
I've played around a bit, and this is the simplest code I can come up with that demonstrates the problem:
<?php
$pdo = new PDO('sqlsrv:Server=xxx', 'username', 'password');
$sql = "select 'aa', cast(char(0x8f) as varchar)";
$query = $pdo->query($sql);
$r = $query->fetch(PDO::FETCH_ASSOC);
var_dump($r);

What seems to be important to trigger the segfault is the position of 0x8f compared to the length of the prior column. For example:
'a', 0x8f -> ok
'aa', 0x8f -> segfault
'aa', 'b'+0x8f' -> ok
'aaa', 'b'+0x8f -> segfault

I have found a few characters that do this: 0x81, 0x8d, 0x8f, 0x90, 0x9d
I've tested this on centos 7 (php 7.1.5 from remi repo).
Sql Server version info:
Microsoft SQL Server 2016 (SP1) (KB3182545) - 13.0.4001.0 (X64)
	Oct 28 2016 18:17:30
	Copyright (c) Microsoft Corporation
	Enterprise Edition (64-bit) on Windows Server 2012 R2 Datacenter 6.3 <X64> (Build 9600: ) (Hypervisor)

Hi @brettmc,
Thank you for the repro script. Which version of the driver ( php --ri pdo_sqlsrv ) are you using? I was unable to reproduce segmentation fault with the latest PDO_SQLSRV.
Please try the script with the latest version and let me know if the issue still persists.
sudo pecl install pdo_sqlsrv-4.2.0preview
You can also download the binaries here .

Hi @ulvii ,
I have been able to replicate with pdo_sqlsrv-4.2.0preview running in docker.  I was installing package mssqlodbc via remi repo (msodbcsql-<IP_ADDRESS>-2.el7.remi.x86_64)
I switched over to msodbcsql (msodbcsql-<IP_ADDRESS>-1.x86_64) and it works as expected, so I guess the issue was fixed between these versions. Thankyou for your assistance!

@ulvii I will be nice to be able to install recent msodbc <IP_ADDRESS>, but I can't find the tarball anywhere
Installation script still refer to <IP_ADDRESS>:
https://github.com/Microsoft/msphpsql/blob/PHP-7.0-Linux/ODBC install scripts/installodbc_redhat.sh

Idem from https://msdn.microsoft.com/fr-fr/library/hh568454(v=sql.110).aspx

@brettmc, glad you could solve the issue.
@remicollet please see #433. Also not that, PHP-7.0-Linux branch has been archived and we are no longer updating it. For latest source code and instructions use dev  branch. You can also use master branch which gets updated after every release.


Randomizer doesn't run

Commit version aa7b51d
System.NotSupportedException: An attempt was made to load an assembly from a network location which would have caused the assembly to be sandboxed in previous versions of the .NET Framework. This release of the .NET Framework does not enable CAS policy by default, so this load may be dangerous. If this load is not intended to sandbox the assembly, please enable the loadFromRemoteSources switch. See http://go.microsoft.com/fwlink/?LinkId=155569 for more information.
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File "Randomizer.py", line 2, in
File "", line 1027, in _find_and_load
File "", line 1006, in _find_and_load_unlocked
File "", line 688, in _load_unlocked
File "PyInstaller\loader\pyimod03_importers.py", line 495, in exec_module
File "Bloodless.py", line 1, in
File "", line 1027, in _find_and_load
File "", line 1006, in _find_and_load_unlocked
File "", line 688, in _load_unlocked
File "PyInstaller\loader\pyimod03_importers.py", line 495, in exec_module
File "Manager.py", line 43, in
System.IO.FileLoadException: Could not load file or assembly 'file:///E:\Mozzarella\Randomizers\BRotN True Random\Tools\UAssetAPI\UAssetAPI.dll' or one of its dependencies. Operation is not supported. (Exception from HRESULT: 0x80131515)
File name: 'file:///E:\Mozzarella\Randomizers\BRotN True Random\Tools\UAssetAPI\UAssetAPI.dll' ---> System.NotSupportedException: An attempt was made to load an assembly from a network location which would have caused the assembly to be sandboxed in previous versions of the .NET Framework. This release of the .NET Framework does not enable CAS policy by default, so this load may be dangerous. If this load is not intended to sandbox the assembly, please enable the loadFromRemoteSources switch. See http://go.microsoft.com/fwlink/?LinkId=155569 for more information.
at System.Reflection.RuntimeAssembly._nLoad(AssemblyName fileName, String codeBase, Evidence assemblySecurity, RuntimeAssembly locationHint, StackCrawlMark& stackMark, IntPtr pPrivHostBinder, Boolean throwOnFileNotFound, Boolean forIntrospection, Boolean suppressSecurityChecks)
at System.Reflection.RuntimeAssembly.InternalLoadAssemblyName(AssemblyName assemblyRef, Evidence assemblySecurity, RuntimeAssembly reqAssembly, StackCrawlMark& stackMark, IntPtr pPrivHostBinder, Boolean throwOnFileNotFound, Boolean forIntrospection, Boolean suppressSecurityChecks)
at System.Reflection.RuntimeAssembly.InternalLoadFrom(String assemblyFile, Evidence securityEvidence, Byte[] hashValue, AssemblyHashAlgorithm hashAlgorithm, Boolean forIntrospection, Boolean suppressSecurityChecks, StackCrawlMark& stackMark)
at System.Reflection.Assembly.LoadFrom(String assemblyFile)
at Python.Runtime.AssemblyManager.LoadAssemblyPath(String name)
at Python.Runtime.CLRModule.AddReference(String name)
[79248] Failed to execute script 'Randomizer' due to unhandled exception!

Try going under Tools>UAssetAPI, right click on the dll, go to properties, click on Unblock and hit apply. Do this for both dlls and see if that fixes it.


[Feature]: Add Ignore SSL Warnings and Disable Web Security for FireFox browser

Feature description
Hello there,
Chrome browser has many args flags to use and some (not many) of the flags can be used for FireFox.
If possible to add 2 flags from the chrome browser to the Firefox. (to have the same functionality)
--disable-web-security
--ignore-certificate-errors
Would appreciate it!

I believe --ignore-certificate-errors is the same as acceptInsecureCerts that can be set when launching or connecting to a browser. This option works cross-browser.
@whimboo does Firefox have an equivalent for --disable-web-security?

What does --disable-web-security exactly do?

Mostly disables CORS restrictions https://peter.sh/experiments/chromium-command-line-switches/#disable-web-security

After taking a look I wonder if the following works for Firefox: https://stackoverflow.com/a/72887545. If yes, it would just be a preference that you have to set in your config.

@whimboo I think that does not work as expected: setting it to true rejects every CORS request with an error that CORS is disabled instead of allowing it to proceed.