Questions tagged [ibm-eventstreams]

IBM Event Streams is an event-streaming platform based on Apache Kafka.

IBM Event Streams is an event-streaming platform based on the open-source Apache Kafka project, providing a high-throughput, fault-tolerant, pub-sub technology for building event-driven applications.

14 questions
8
votes
1 answer

could kafka-connect distributed worker work with topic 'connect-offset' with configuration 'cleanup.policy=compact,delete'

I started a kafka-connect distributed worker cluster which uses the topic connect-offset for offset storage: offset.storage.topic=connect-offset Since the broker is provided with default policy 'cleanup.policy=delete', when creating a topic with…
shawnzhu
  • 7,233
  • 4
  • 35
  • 51
4
votes
1 answer

node-rdkafka producer isn't receiving a 'ready' event

I'm trying to setup a producer to send messages, using node-rdkafka, to an Event Stream Service in IBM Cloud, however I've not been able to receive the 'ready' event back from the server. I've had a day trying to figure this out and I'm sure it's…
Neil
  • 89
  • 2
  • 8
4
votes
2 answers

ibm-eventstreams-dev does not deploy into IBM Cloud Private

I tried to install ibm-eventstreams-dev v 0.1.1 into IBM Cloud Private and i get an error message: Internal Service Error : Chart Incompatible with Tiller v2.6.0
rob9nicholson
  • 191
  • 1
  • 7
3
votes
2 answers

Python Kafka Client - No error but not working

I am running the confluent_kafka client in python. Currently I get no errors when trying to produce and then consume messages, but the problem is the producer says it succeeds, but the consumer can't find any messages. I have created a topic and…
2
votes
0 answers

Cannot connect to Apache Kafka with Confluent.Kafka hosted on IBM

I am trying to connect to IBM's managed Apache Kafka solution. This is what IBM states in its documentation to…
jayasurya_j
  • 1,519
  • 1
  • 15
  • 22
2
votes
1 answer

Configure kafka topic retention policy during creation in spring-mvc?

Configure retention policy of all topics during creation Trying to configure rentention.ms using spring, as I get an error of: Caused by: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.PolicyViolationException: Invalid…
2
votes
1 answer

Does ibm-eventstreams support Kafka ACLs?

Wanted to check if ibm-eventstreams that I can deploy on IBM Cloud Private (ICP) 2.1.0.3, supports Kafka SASL authentication and ACLs applied to specific topics? I was referring to this developerWorks article about Kafka…
1
vote
1 answer

Using IBM EventStreams with C/C++

I need to use Event Streams from a C++ program. Looking for sample code. Tried ./rdkafka_example from librdkafka, I dont get any error message but messages dont get through. It may an be authorization issue as I could not find where to supply…
1
vote
1 answer

spring kafka consumer does not work sometimes

The consumer does not work sometimes and sometimes it does, not able to figure the issue. spring boot - 1.5.21.release kafka client - 0.11.0.0 kafka servers - IBM event stream service on cloud. application…
1
vote
0 answers

Spark Streaming readStream unable to read from secure Kafka (EventStreams)

I'm trying to send the data from a program to a secure Kafka cluster (EventStreams on IBM Cloud - Cloud Foundry Services), then in my consumer application (which is spark streaming), I'm trying to read the data from the same kafka source. Here are…
0
votes
0 answers

node-rdkafka on macOS: Error: Invalid value "sasl_ssl" for configuration property "security.protocol"

I am trying to connect to IBM Event Streams (previously Message Hub) using node-rdkafka and seeing the below error /Users/VMac/Documents/VMAC/Code/GIT/kafka-log-simulator/node_modules/node-rdkafka/lib/client.js:54 this._client = new…
Vidyasagar Machupalli
  • 2,737
  • 1
  • 19
  • 29
0
votes
0 answers

In IBM Event Streams SaaS on Cloud, where can I look for failing client connection attempts?

I am trying to configure a Kafka client (it happens to be a DataPower appliance running V10) to my IBM Event Streams SaaS instance in IBM Cloud. But the Kafka client keeps throwing an error: Broker transport failure Initialization failed Where…
0
votes
0 answers

Wiring an Event Streams Kafka Topic to Grafana in IBM Cloud

How do I wire up a Kafka Topic from Event Streams to Grafana in IBM Cloud's console? I can't seem to find a connector that will work, but the documentation seems to suggest that this is not only possible, but recommended.
0
votes
2 answers

Errors when deploying ibm-eventstreams-dev into local environment

I tried to install ibm-eventstreams-dev v 0.1.2 into my Mac. After I installed eventstreams into my Mac, there's always several pods that can't run. It includes three kafka pods: es-ibm-es-kafka-sts-0/1/2, es-ibm-es-ui-deploy-69758d9dfd-kc2zx,…