[GitHub] sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d
sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d URL: https://github.com/apache/pulsar/issues/3362#issuecomment-453661576 remove data and logs directory, create a brand new topic. before starting consumer, server is good. as soon as start the consumer, no producer. it has same error. This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d
sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d URL: https://github.com/apache/pulsar/issues/3362#issuecomment-453655217 i am running local standalone mode. I already removed the data and logs directory, server still kept throwing this error. What files/directory do I need to delete to do the fresh restart.? This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d
sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d URL: https://github.com/apache/pulsar/issues/3362#issuecomment-453636095 Consumer log: 20190111.142908.328 INFO [org.apache.kafka.clients.consumer.ConsumerConfig] ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = latest bootstrap.servers = [pulsar://localhost:6650] check.crcs = true client.id = connections.max.idle.ms = 54 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = 222 heartbeat.interval.ms = 3000 interceptor.classes = null key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 30 max.poll.records = 500 metadata.max.age.ms = 30 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 3 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.ms = 50 request.timeout.ms = 305000 retry.backoff.ms = 100 sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 6 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 1 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer - 20190111.142908.474 WARN [org.apache.kafka.clients.consumer.ConsumerConfig] The configuration 'AAA' was supplied but isn't a known config. - 20190111.142908.475 WARN [org.apache.kafka.clients.consumer.ConsumerConfig] The configuration 'BBB' was supplied but isn't a known config. - 20190111.142908.475 WARN [org.apache.kafka.clients.consumer.ConsumerConfig] The configuration 'thread_number' was supplied but isn't a known config. - 20190111.142908.475 WARN [org.apache.kafka.clients.consumer.ConsumerConfig] The configuration 'socket.timeout.ms' was supplied but isn't a known config. - 20190111.142908.477 INFO [org.apache.kafka.common.utils.AppInfoParser] Kafka version : 0.10.2.1 - 20190111.142908.477 INFO [org.apache.kafka.common.utils.AppInfoParser] Kafka commitId : e89bffd6b2eff799 - 20190111.143140.410 INFO [org.apache.kafka.clients.consumer.ConsumerConfig] ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = latest bootstrap.servers = [pulsar://localhost:6650] check.crcs = true client.id = connections.max.idle.ms = 54 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = 222 heartbeat.interval.ms = 3000 interceptor.classes = null key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 30 max.poll.records = 500 metadata.max.age.ms = 30 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 3 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.ms = 50 request.timeout.ms = 305000 retry.backoff.ms = 100 sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 6 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 1 ssl.cipher.suites = null
[GitHub] sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d
sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d URL: https://github.com/apache/pulsar/issues/3362#issuecomment-453633946 I set bootstrap.servers pulsar://localhost:6650 in the properties This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d
sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d URL: https://github.com/apache/pulsar/issues/3362#issuecomment-453631964 Ok. I set the consumer props.put(KafkaKeys.VALUE_DESERIALIZER, ByteArrayDeserializer.class.getName()); props.put(KafkaKeys.KEY_DESERIALIZER, StringDeserializer.class.getName()); in producer, I have the same setting but it is the serializer. now I am getting the following error in the pulsar server: 14:16:27.791 [pulsar-io-49-12] WARN org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:51545] Got exception IndexOutOfBoundsException : writerIndex: 1179652 (expected: readerIndex(4) <= writerIndex <= capacity(20)) java.lang.IndexOutOfBoundsException: writerIndex: 1179652 (expected: readerIndex(4) <= writerIndex <= capacity(20)) at io.netty.buffer.AbstractByteBuf.writerIndex(AbstractByteBuf.java:118) ~[io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final] at org.apache.pulsar.common.api.PulsarDecoder.channelRead(PulsarDecoder.java:83) ~[org.apache.pulsar-pulsar-common-2.2.1.jar:2.2.1] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final] at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final] at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310) [io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final] at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284) [io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final] at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340) [io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final] at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1414) [io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362) [io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348) [io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final] at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:945) [io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final] at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:146) [io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:649) [io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:584) [io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final] at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:501) [io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final] at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463) [io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886) [io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final] at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [io.netty-netty-all-4.1.22.Final.jar:4.1.22.Final] at java.lang.Thread.run(Thread.java:745) [?:1.8.0_45] This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
[GitHub] sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal base64 character 2d
sautran commented on issue #3362: java.lang.IllegalArgumentException: Illegal
base64 character 2d
URL: https://github.com/apache/pulsar/issues/3362#issuecomment-453617931
@merlimat , yes, I set the key as StringSerializer
props.put("key.serializer",
StringSerializer.class.getName());
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
