12/31/2023 0 Comments Conduktor kafka 20mdocker run -rm confluentinc/cp-kafka bash -c 'kafka. To connect your Kafka clients to the gateway update the rvers in the client properties to be localhost:6969. Check access to Topic: in different ways (but in the same cmd-console) docker run -rm confluentinc/cp-kafka bash -c 'kafka-topics -bootstrap-server 192.168.2.22:9092 -list'. The Conduktor Gateway to Kafka cluster connection information Kafka Client to Conduktor Gateway configuration By default the Conduktor Open Source Gateway does not run with any security enabled. at .(KafkaAdminClient.java:547) at .admin.KafkaAdminClient.(KafkaAdminClient.java:516) at .(KafkaAdminClient.java:472). Create Topic: docker exec kafka1 kafka-topics -bootstrap-server localhost:9092 -create -topic my-Windows-Topic-1. TartSupervisor saw failure : Failed to create new KafkaAdminClient .KafkaException: Failed to create new KafkaAdminClient at .(KafkaAdminClient.java:479) at .(Admin.java:61) at .(AdminClient.java:39) at $.createAdminClient(KafkaClient.scala:120) at $.apply(KafkaClient.scala:55) at $.$anonfun$start$1(MainApp.scala:37) at $.$anonfun$init$1(ConsumerGroupCollector.scala:149) at .BehaviorImpl$DeferredBehavior$$anon$1.apply(BehaviorImpl.scala:120) at $.start(Behavior.scala:168) at .RestartSupervisor.restartCompleted(Supervision.scala:383) at .RestartSupervisor.aroundReceive(Supervision.scala:243) at .InterceptorImpl.receive(InterceptorImpl.scala:85) at $.interpret(Behavior.scala:274) at $.interpretMessage(Behavior.scala:230) at .(ActorAdapter.scala:131) at .(ActorAdapter.scala:107) at (ActorCell.scala:580) at (ActorCell.scala:548) at (Mailbox.scala:270) at (Mailbox.scala:231) at (Mailbox.scala:243) at java.base/.doExec(ForkJoinTask.java:373) at java.base/$WorkQueue.topLevelExec(ForkJoinPool.java:1182) at java.base/.scan(ForkJoinPool.java:1655) at java.base/.runWorker(ForkJoinPool.java:1622) at java.base/.run( ForkJoinWorkerThread.java:165 )Ĭaused by: .config.ConfigException: The specified value of must be no smaller than the value of. Is there a link to the various environment variables one can pass to the docker container? I'm getting this error constantly: Wow, just tried this out with an MSK cluster and it worked right out of the bat which is super nice given that I abandoned conduktor desktop because i wasn't interested in the proxy legwork required.
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |