Ed Mitchell comments

Results 26 comments of


                                            Ed Mitchell

Running the quickstart guide throws java.net.SocketTimeoutException

I would recommend using the cp-ksqldb-server and cp-ksqldb-cli containers, which are published with ARM64 images: ``` [...] ksqldb: image: confluentinc/cp-ksqldb-server:7.6.0 ports: - "8088:8088" environment: KSQL_LISTENERS: http://ksqldb:8088 KSQL_BOOTSTRAP_SERVERS: kafka:9092 KSQL_KSQL_SCHEMA_REGISTRY_URL: http://schema-registry:8081...

Custom SASL Mechanisms for Kafka

Hi @dalelane. My apologies for the incredibly slow response time. The email for this must've gotten lost in the shuffle. I think option 2 is probably the cleanest, if for...

Custom SASL Mechanisms for Kafka

I'm interested in picking this up if no one else is, but I don't currently have the bandwidth to visit it.

Question: Is there a way to get the status of all consumers inside a consumer group?

You can use the [describeGroups Admin](https://kafka.js.org/docs/admin#describe-groups) function to list the group members with their IPs and currently subscriptions.

fix: #19020 Check permissions using native Postgres functions to support GROUPs and ROLEs based access control

It's unclear why the Connector Node Integration Tests are failing. The one that's failing is Error: Errors: Error: PostgresSourceTest.testLines:145 » Execution io.grpc.StatusRuntimeException: UNKNOWN I can look deeper, but if anyone...

Kafka Microservice Consumer Healthcheck

My workaround I've found is to move the custom microservice implementation into a module in the application context, add a public method to expose the consumer and then use app.resolve...