can use to buffer records waiting to be sent to the server. # If records are sent faster than they can be delivered to the server the producer will either block or throw an exception # buffer.memory=33554432 are being sent to the same Kafka partition. The default value is 16384. • the buffer.memory defines the size of the buffer the appender uses to send to the Kafka broker. The default value is 33554432 your websocket client on this URL. You can use curl as client to test: curl --include \ --no-buffer \ --header "Connection: Upgrade" \ --header "Upgrade: websocket" \ --header "Host:

can use to buffer records waiting to be sent to the server. # If records are sent faster than they can be delivered to the server the producer will either block or throw an exception # buffer.memory=33554432 are being sent to the same Kafka partition. The default value is 16384. • the buffer.memory defines the size of the buffer the appender uses to send to the Kafka broker. The default value is 33554432

bootstrap)(version>=3.4.0)(!(version>=4.0.0))) [81.0] osgi.wiring.package; (&(osgi.wiring.package=org.jboss.netty.buffer)(version>=3.4.0)(!(version>=4.0.0))) [81.0] osgi.wiring.package; (&(osgi.wiring.package=org.jboss @param buffer the beginning string typed by the user * @param cursor the position of the cursor * @param candidates the list of completions proposed to the user */ public int complete(String buffer, int add("Mike"); delegate.getStrings().add("Eric"); delegate.getStrings().add("Jenny"); return delegate.complete(buffer, cursor, candidates); } } Blueprint with completer Using Blueprint, you can "inject" the completer

bootstrap)(version>=3.4.0)(!(version>=4.0.0))) [81.0] osgi.wiring.package; (&(osgi.wiring.package=org.jboss.netty.buffer)(version>=3.4.0)(!(version>=4.0.0))) [81.0] osgi.wiring.package; (&(osgi.wiring.package=org.jboss